序列号添加不同步答案

【问题标题】：serial number add not synchronized序列号添加不同步
【发布时间】：2018-11-04 20:31:16
【问题描述】：

不知道放了所有我能想象到的“同步”后，还是线程不安全，求助，非常感谢！多线程争相加序号'a'。应该线程Demo的run方法可以同步？无论如何，我将它添加到“public void run()”一个同步的，它仍然显示一个不安全的消息。

package stackoverflow;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class NumberEx {

    public static void main(String[] args) {
        // TODO Auto-generated method stub
        ExecutorService service=Executors.newCachedThreadPool();
        for(int i=0;i<10;i++) {
            service.execute(new ThreadDemo());
        }
        service.shutdown();

    }
}


package stackoverflow;

import java.io.FileNotFoundException;
import java.io.PrintWriter;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
import java.util.concurrent.atomic.AtomicInteger;

public class ThreadDemo implements Runnable  {
    private static volatile int a = 0;
    private static volatile List<Integer> list=new ArrayList<Integer>();
    static PrintWriter writer;
    static {
        try {
            writer=new PrintWriter("./src/out.txt");
        } catch (FileNotFoundException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }

    @Override
    public void run()  {

         while (a< 1000) {
                //critical section
                a= increment(a);
                //end
         }
            writer.close();

    }

    private static synchronized int increment(int a)  {

        writer.print("<<<<============"+Thread.currentThread().getName()+"========================     ");

        a=a+1;
        Integer temp=new Integer(a);

       writer.print(" Thread["+Thread.currentThread().getName()+"]" + ":"+ a);
       writer.print("      ============="+Thread.currentThread().getName()+"=======================>>>>>    "); 
        if(list.contains(temp)) {
            System.out.println("repeat number"+temp);
            Iterator<Integer> iter=list.iterator();
            while(iter.hasNext()) {
                System.out.print(iter.next()+" ");
            }
            System.exit(0);
        }else {
            list.add(temp);
        }
       writer.println(" "+temp+"\n");

        return a;
    } 

}

【问题讨论】：

毫无疑问，并发编程不仅仅是“把synchronized放在你能想到的任何地方”。您在说什么“显示不安全的消息”？
@Kayaman，也许你并不意外，但是根据这个论坛中不断出现的作业问题，似乎有很多老师在传播关于互斥锁的坏信息（为什么、何时以及什么时候不使用它们），以及一般的线程。

标签： java multithreading thread-safety threadpool

【解决方案1】：

我可能是错的，但我认为你需要包围

//critical section
a= increment(a);
 //end

使用同步块并像这样引入锁定对象：

private static final Object LOCK = new Object();

@Override
public void run() {

    while (true) {
        synchronized (LOCK) {
            if(a<1000){
                //critical section
                a = increment(a);
                //end
            }else{
                break;
            }
        }
    }
}

你还需要检查同步块内部的条件，否则你会得到高于1000的数字。

编辑。之前的答案不正确。

【讨论】：

不，'this'引用当前线程，肯定不行！因为同步锁定当前线程，而不是共享资源
带输出，重复227

【解决方案2】：

对不起这个愚蠢的问题，我最近了解了对象监视器，最后通过对象同步解决了ti

【讨论】：