执行线程“一个接一个”

Question

有一个 n 线程可以访问的单例类。
每个线程都加载这个类的实例并循环调用这个类的一个方法。

我必须控制执行流程，以便每个线程都可以调用方法一并暂停，只有在所有线程调用该方法后，必须恢复它们的工作。 线程可以按任意顺序调用方法，只是它们都必须在移动循环之前执行一次方法。

这是我尝试做的：

在线程中：

 while ( some condition){
    ObjectType obj = theSingleton.getInstance().getSharedObject();
    obj.SomeMethod(threadID);
   if (obj.waitisneeded())
    synchronized (obj ) {
       obj.wait();
    }
}

我在 SomeMethod 中做了什么：

public  synchronized void SomeMethod(String threadID) {
 hashMap.put(threadID,true);
 some job here
}

需要等待：

public  synchronized boolean waitisneeded(){
{

   Iterator iter = hashMap.entrySet().iterator();

   boolean alldone = false;

   while (iter.hasNext()) { 
      Map.Entry me = (Map.Entry) iter.next();
      String key = me.getKey().toString();
      alldone = (Boolean)me.getValue();

      if(!alldone)  {
    return false;
       }
   }

  //set all values to false 
 iter = hashMap.entrySet().iterator();
 while (iter.hasNext()) { 
   Map.Entry me = (Map.Entry) iter.next();
    String key = me.getKey().toString();
   me.setValue(false);      
 }      
 this.notifyAll();
 return true;               

运行它给我带来了意想不到的结果和死锁。

我该如何解决？

注意：我不能改变线程的创建方式，我只能改变那些方法！！！ （加上等待所在的线程中的while循环）

Answer 1

如果知道线程数，可以使用CyclicBarrier：

static final CyclicBarrier barrier = new CyclicBarrier(numberOfThreads);

然后，当您想让所有线程等待其他线程时，您调用：

barrier.await();

如果有一个线程尚未到达该行，则调用await() 的线程将阻塞。一旦所有线程到达那里并调用await()，它们都会恢复。

每次你必须构建一些同步机制时，一定要检查包java.util.concurrent。那里有很多精彩的课程，由专家创建。大多数时候你不需要自定义的东西，如果你这样做了，同一个包中有一些类几乎不需要直接使用等待/通知——相信我，你想避免使用这些直接方法；如您所见，您很容易陷入僵局！

Answer 2

这是一种典型的多线程情况，称为 Rendez-Vous（法语单词，意为“约会”）。基本上，您的N 线程将有一个约会，并且都应该在某个时间点等待，直到所有线程都到达。正如@Bruno 提到的，您可以使用CyclicBarrier 对象来管理这种情况。如果您的方案只运行一次，那么您也可以使用CountDownLatch。

以下是实现此目的的方法：

static final CountDownLatch rendezVousPoint = new CountDownLacth(numberOfThreads);

//Every thread does the following right before waiting on the rendez vous point
rendezVousPoint.countDown();
rendezVousPoint.await();

在这种情况下，每个线程都会阻塞await()方法，直到最后一个线程到达并释放所有线程（rendezVousPoint计数达到0）