定期通知多个线程

Question

我正在做一个项目，它使用原始Java并发结构，如等待（）、通知（）、通知（）、Thread.run（）、html" target="_blank">同步化等。在我的项目中，有多个线程（线程类的扩展）会定期从队列中获取一个对象。因此，我使用了一个有内部TimerWork类的Timer类。

我的问题是，我无法获得如何让其他线程定期唤醒。我的主要类不是这些线程或计时器类。因此，我从另一个类调用它们的运行。我不知道如何让这些线程每100毫秒等待和通知一次。我的计时器类是：

public class Controller extends Timer{

    int counter;
    TimerTask task;
    final Controller c = this;

    public class PeriodicTime extends TimerTask {

        @Override
        public void run() {

            if(counter > 0) {
                //do some stuff to wake up threads

            }
            counter++;
        }
    }

    Controller () {
        super ();
        this.task = new PeriodicTime();
        counter = 0;
        this.schedule(task, 300, 100);
    } 
}

我的线程类是：

public class Element extends Thread {


    public void run() {

        // do something to get an object from another class (a queue)
    }
}

现在，我真的很困惑如何对线程类进行周期性释放。我甚至不知道是否使用等待（）/通知（）。

正如我之前所说的，我将创建多个元素类。他们将同步工作。然后，我该怎么办？

Answer 1

创建一个表示互斥体的对象列表，每个元素线程将从列表中获取一个互斥体，而计时器任务将获取列表。

当时间段过期时，TimerTask对每个互斥对象调用notify（）。这会唤醒元素线程。

元素线程处理队列中的数据，完成后，每个线程都对互斥对象调用wait（）。

现在，您需要在队列中内置线程安全性，因为有多个使用者，而不是阻塞逻辑，因为它是由TimerTask处理的。

此外，如果我理解正确的话，你希望元素在处理数据时把一些东西放回队列。为此，你可以使用一个辅助队列，在元素完成后，你可以把它排入第一个队列，或者你可以交换它们（这是由时间任务完成的，需要一个原子计数器，当元素醒来时它会递增，当它进入睡眠时它会递减）。或者，你可以使用一个“停止”值，你可以在唤醒元素之前把它放入队列，让它们一直工作到到达它。对于N个元素线程，你需要输入N个停止值，这样它们都能得到消息。

如何使用互斥锁：

List<Object> mutexList;
//initialize the list with plain Objects. You just need them to be separate instances.
....
//When creating Element threads add one object from the list to each Element.
....
//in Element code
public class Element extends Thread {
   //This is one element from the list 
   private Object mutex;


    public void run() {
       // do something to get an object from another class (a queue)
       //....
       synchronized(mutex){ 
          mutex.wait();
       }
    }
}
// in timerTask code
 public class PeriodicTime extends TimerTask {

    List<Object> mutexList;

    @Override
    public void run() {

        if(counter > 0) {
            //do some stuff to wake up threads
           for(Object mutex:mutexList){
                mutex.notify();
           }
        }
        counter++;
    }
}