java - java中的事件循环

Question

我实际上正在尝试为 Nashorn (java 8) 编写一个事件循环，以便来自异步操作的回调(我启动的线程，例如，连接到远程服务或进行长时间运行的计算)将被放入一个排队并按顺序执行(不是并行)。我通过将回调函数放在 ConcurrentLinkedQueue 上并使用 ScheduledExecutorService 作为循环来检查要执行的回调队列。

工作正常，但我的问题是:

1) 在不拖 CPU 的情况下，我可以使用多短的间隔？我将运行其中的多个，并且它们必须相互独立。因此可能有 50 个线程都在运行它们自己的“事件循环”。例如，此执行程序尝试每 10 毫秒运行一次我的可运行对象....

Executors.newSingleThreadScheduledExecutor().scheduleAtFixedRate(<cbRunnable>, 0, 10, TimeUnit.MILLISECONDS);

2) 这种方法是否优于:

while (true) {
   // check queue and execute any callback...
}

3)有没有更好的办法？

Answer 1

答案完全取决于你在这个 block 中做什么:

while (true) {
    // check queue and execute any callback...
}

如果队列检查阻塞直到元素可用，那么就 CPU 使用率而言，这是“最有效”的轮询方式。如果检查未阻塞，则调用线程将自旋，并且您将在循环期间以满负荷运行一个硬件线程 - 但是，这消除了同步成本，并为您提供绝对最佳的 响应时间。以下是一些示例:

阻塞队列(对 CPU 的负担最少，但以同步为代价)

Queue<T> q = new LinkedBlockingQueue<>();
...
while(true){
    T t = q.take();
    //t will never be null, do something with it here.
}

非阻塞队列(最耗费 CPU，但没有同步成本)

Queue<T> q = new LinkedList<>();
...
while(true){
    T t;
    while((t = q.poll()) == null); //busy polling!
    //t will never be null, do something with it here
}

调度执行器服务

最后...如果您最终使用预定的执行程序服务，您将在轮询之间强制执行一些非零等待时间。与完整的 BlockingQueue 实现相比，这在 CPU 方面几乎一样高效，但您也被迫在响应时间上受到影响，直到调度间隔。什么对你的应用程序来说是“最好的”将取决于你是否有能力等待轮询之间的最短 sleep 时间(我认为你可以安排微秒......？)，或者你是否需要更快的东西，比如繁忙的轮询方案。