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

答案完全取决于你在这个块中做什么：

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 方面的效率几乎是一样的，但您也被迫在响应时间上受到影响，直到调度间隔。什么对您的应用程序来说是“最好的”将取决于您是否有能力在轮询之间等待最短的睡眠时间（我认为您可以将时间安排在微秒内......？），或者您是否需要更快的时间，例如繁忙的轮询方案。