static class ReliableSingleThread implements Runnable { O runnable; bool trigger; Thread thread; WeakReference threadBeingCancelled; S name = "Single Thread"; F0 enter; // optional ownership marker, e.g. for DynModules *(O *runnable) {} void trigger() { go(); } synchronized void go() { trigger = true; if (!running()) { temp callF(enter); thread = startThread(name, r { temp callF(enter); _run(); }); } } public void run() { go(); } void get() { go(); } // so you can use the ! syntax synchronized bool running() { ret thread != null; } // use only if this is the last time you trigger this void triggerAndWait() { trigger(); while (running()) sleep(1); } void _run() ctex { while licensed { synchronized(this) { if (!trigger) { thread = null; break; } Thread oldThread = getWeakRef(threadBeingCancelled); if (oldThread != null && oldThread != currentThread()) oldThread.join(); trigger = false; } pcallF(runnable); } } synchronized void cancel() { if (thread == null) ret; threadBeingCancelled = new WeakReference(thread); cancelAndInterruptThread(thread); thread = null; } void cancelAndTrigger() { cancel(); trigger(); } synchronized bool triggered() { ret trigger; } void cleanMeUp { cancel(); } }