指尖上的代码--之ACTIVEMQ（3）

?

?

public void wakeup() throws InterruptedException { synchronized (runable) {if (queued || shutdown) { return; } queued = true; // The runTask() method will do this for me once we are done // iterating. if (!iterating) { executor.execute(runable); } } }?

其中queued和interating这两个变量是为了防止多次重复调用的。

?