具有竞争队列的​​ Java 线程池

Question

我有一种情况，我想使用 Java 固定线程池的扩展。我有 N 组可运行对象，我想争夺资源。但是，我希望使用的线程总数保持不变。这里概述了我希望其工作的方式

1. 分配一个具有 N 个线程和 M 个队列的对象；
2. 将作业 n 调度到队列 m 上。
3. 有一个指向第一个队列的指针 重复 一个。如果当前正在使用最大线程数等待。 b.弹出当前队列中的作业 c.将指针移过一个队列（或从最后一个队列到第一个队列）

首先，这样的东西是否已经存在？其次，如果没有，我对编写自己的线程池感到紧张，因为我知道编写自己的线程池可能很危险。谁能给我指出一些写我自己的好例子。

Answer 1

您最好的选择可能是创建自己的队列实现，该队列在其他队列中循环。例如（伪代码）：

class CyclicQueue {
队列队列[]；
整数当前= 0；

CyclicQueue(int size) {
  queues = new Queue[size];

  for(int i=0; i<size; i++)
    queues[i] = new LinkedList<T>();
}

T get() {
  int i = current;
  T value;
  while( (value = queues[i].poll() == null) {
    i++;
    if(i == current)
      return null;
  }
  return value;
}

当然

，有了这个，如果你想要阻止，你需要自己添加它。

在这种情况下，您可能需要为每个队列一个自定义队列，它可以通知父队列该值已添加。