我正在寻找使 ExecutorService 成为按对象(键)排序的 FIFO 的方法,即
- 对于给定的键,事件将按照它们到达的顺序进行处理。
- 对于给定的键,一次只会处理一个事件。
Netty 3 有 OrderedMemoryAwareThreadPoolExecutor但它与 Netty 相关。
Guava 有 EventBus但是否保证 FIFO 尚不清楚。
我可以使用类似 JKeyLockManager 的方式锁定 key 但为了保证 FIFO,我将不得不冒在调度程序线程中争用的风险。
这个问题有什么通用的解决方案吗?
最佳答案
如果你想要简单,我会使用一些像这样的 FIFO 执行器
static final int executors = Runtime.getRuntime().availableProcessors() * 2;
ExecutorService[] executors = new ExecutorService[executors];
// fill with single threaded executors.
public Future submit(Object actorId, Runnable r) {
int h = (actorId.hashCode() & 0x7FFF_FFFF) % executors;
return executors[h].submit(r);
}
除非工作负载高度不平衡,否则这将使您的所有 CPU 都处于忙碌状态,而无需锁定。
关于java - 执行器服务 : FIFO ordering by key,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/36870564/