Java线程调度

Question

我有一个MainClass，一个Worker类和一个Supervisor类。在MainClass中，我创建了10个Worker类和一个Supervisor类，它们在不同的线程中运行。

class MainClass {

   public static void main(String args[]) {

   for (int i=0; i<10 ;i++) {
      Thread t = new Thread( new Worker());
      t.start();
   }

   (new Thread(new Supervisor()).start();

}

.

class Worker extends Thread {
  public void run() {
    while(true) {
      if(some_condition) {
        //do stuff
      } else {
        // pause thread execution for undefined time.
      }
    }
  }
}

.

class Supervisor extends Thread {
  public void run() {
    while(true) {
      if(some_condition) {
        // restart Workers thread that are paused.
      } 
      // do other stuff
    }
  }
}

我不知道如何实现这个，因为每个线程中的条件是相互独立的，所以我不需要同步，所以我不能使用等待通知。

Answer 1

据我所知，你想创建单独的线程池，其中包括10个工人或根据你的要求的数字。

就池而言，您可以在java中检查ThreadPoolExecutor。util。并发api。在内部ThreadPoolexecutor还为运行任务创建工作线程。

尝试阅读ThreadPoolExecutor它可能会帮助您或请详细说明您的问题您希望通过这个问题实现的最终目标是什么。

Answer 2

我不知道如何实现这个，因为每个线程中的条件是相互独立的，所以我不需要同步，所以我不能使用等待通知。

你当然可以。

这里的微妙之处在于，可能Supervisor实际上并不知道工作线程是否真的暂停了。（如果知道，那么条件不是独立的。）

由于Supervisor不知道线程是否真的暂停了（根据假设），所以如果它试图取消已经暂停的线程，您必须设计您想要发生的事情。

a） 一个不支持的人应该什么都不做吗？

b） 或者下次员工试图暂停时，它是否应该立即取消暂停？

如果答案是（b），那么你必须担心线程安全。如果答案是（a），那么您就不会这样做（除非您有其他一些数据要在线程之间传递！）

无论哪种方式，您仍然可以使用等待和通知。