/** the ThreadMessage thread blocks on this before executing any JavaScript */
Semaphore go = new Semaphore();
- /** The MessageQueue (main) thread blocks on this while the ThreadMessage thread is running JavaScript code */
+ /** The Message.Q (main) thread blocks on this while the ThreadMessage thread is running JavaScript code */
Semaphore done = new Semaphore();
/** used to pool ThreadMessages that are not in use */
}
}
ret.f = f;
- MessageQueue.add(ret);
+ Message.Q.add(ret);
}
/** attempts to put this thread into the background to perform a blocking operation; returns false if unable to do so */
/** re-enqueues this thread */
public static void resumeThread() {
ThreadMessage mythread = (ThreadMessage)Thread.currentThread();
- MessageQueue.add(mythread);
+ Message.Q.add(mythread);
mythread.setPriority(Thread.NORM_PRIORITY);
mythread.go.block();
}
synchronized(waiting) {
if (waiting.size() > 0) {
f = (JS.Callable)waiting.remove(false);
- MessageQueue.add(this);
+ Message.Q.add(this);
} else if (spare.size() < 10) {
spare.append(this);
} else {
}
}
- /** this is invoked in the MessageQueue thread */
+ /** this is invoked in the Message.Q thread */
public void perform() {
go.release();
done.block();