java - 多生产者/一消费者 Java 多线程

Question

我有一个产生新线程的 ServerClass。

每个线程都有一个数据块进行处理。每个线程处理“x”块数据并将一些值返回给 ServerClass。ServerClass 平均收集的值并将其传递给线程。线程使用平均值恢复工作。重复相同的过程，直到线程处理完整个数据。

我写了这个，每次执行它都会得到不同的输出。有人可以解释我做错了什么。

ServerClass

public synchronized void put(double[] weight)
{

        //System.out.println(Counter);      

        weights.add(weight);

        if(Counter+1 == NoOfThreads)

        {           

            averageWeights();

            notifyAll();

            Counter =0;

        } else

            try {

                Counter++;

                wait();

            } catch (InterruptedException e) {

    e.printStackTrace();

        }

}

Threads Class

refer // ServerClass Reference

updatedweights // Averaged Value

int slots = data.size() / batchCount;

            for(int i=0; i<slots;i++)

            {

                double[] p = Algo(data,i*batchCount, (i+1)*batchCount, ServerClass.stepSize, labelIndex, refer.updatedweights);

                refer.put(p);

            }

Answer 1

public void put(double[] weight, Threads t)
{
     updatingWVector(weight);
        if(checkCondition())
        {            
            averageWeights();               
            Counter =0;
            synchronized(lock) {
                //System.out.println(t.getId());
                  lock.notifyAll();
            }
        } else
        {

                try {
                    updateCounter();
                    synchronized(lock) {
                        System.out.println(t.getId());
                        lock.wait();
                    }
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
        }
}

Rest在哪里代码lock中 private final Object lock = new Object(); 的所有方法都在synchronized块中。