多线程同步问题

Question

线程2：4

.

.

线程3：7

线程3：8

线程1：9

这是我为正在执行线程的类编写的代码

public class numberentrycreater implements Runnable
{
    final private int max = 100;
    private static int count = 1;
    private String createdBy;
    private SharedBuffer buffer;

    public numberentrycreater(String createdBy ){
        this.createdBy = createdBy;
    }

    public synchronized void  increment(NumberEntry ne){
        System.out.println(ne.getCreatedBy()+": " + ne.getValue());
        if(count<=max){
            count++;
        }
    }

    @Override
    public  void run()
    {
        for(int i=0; i<25; i++){
            if(count<=max){
                NumberEntry ne = new NumberEntry(count,createdBy);
                increment(ne);
                try
                {
                    Thread.sleep(100);
                } catch (InterruptedException e)
                {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }
        }
    }
}

我认为问题在于NumberEntry对象的创建。但我不太确定怎么修好它。如果有人能以任何方式帮助我，那就太好了：）。

Answer 1

这里的同步有点混乱，你得到了很多竞争条件。

首先，在进入synchronized方法之前，您要创建numberentry，因此没有理由认为多个线程不会接收相同的数字。

另外，synchronized方法实际上不会同步。作为方法选项的synchronized只是synchronized（this）{...}的缩写，而this在本例中是每个线程唯一的可运行的，因此它们可以同时输入它。你需要在他们共享的东西上同步。尝试在synchronized(numberentrycreater.class){ } 的方法中放置一个块。