[Java] Thread -- 避免Race Condition (Synchronized)

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了[Java] Thread -- 避免Race Condition (Synchronized)，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1905字，纯文字阅读大概需要3分钟。

内容图文

public class TestRaceCondition implements Runnable{

    public static int counter = 0;

    public static void main(String[] args) {

        List<Thread> threads = new ArrayList<>();
        //產生threads，加入ArrayList
        for( int i=0 ; i < 10 ; i++) {
            TestRaceCondition runnable = new TestRaceCondition();
            Thread t1 = new Thread(runnable,"T"+i);
            threads.add(t1);
        }
        //一起發動所有的thread
        for (Thread thread : threads) {
            thread.start();
        }
        try {
            //main thread 等待所有執行緒結束
            for (Thread thread : threads) {
                thread.join();
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        //印出最後的值
        System.out.println("finally counter = "+counter);

    }

    @Override
    public void run() {
        for ( int i= 0  ; i < 1000 ;i ++){
            incrementCounter();
        }
    }

    public static  void incrementCounter(){   
        counter = counter + 1;
    }

}

[原始程式架構]

設立10個執行序塞入List中，再同時執行程序，各自生成一個Runnable的物件，執行run()，再incrementCounter()

此處會有共搶的Race Condtion發生，避免此狀況，可使用synchronized管控程序

(%所有synchronized標的都需唯一)

1. static 方法 加上 synchronized

所有用到這個方法的都是受到管控的，鎖頭為類別自身(TestRaceCondition.class)  

 public static synchronized void incrementCounter(){  
        counter = counter + 1;
    }

2.方法中設立專鎖物件控管執行方法

    //設立專鎖物件
    public  final static Object locker = new Object(); 
    
    @Override
    public void run() {
        for ( int i= 0  ; i < 1000 ;i ++){
            synchronized (TestRaceCondition.locker)
            incrementCounter();
        }
    }

3. 一般方法中加上 synchronized

所有用到這個方法的都是受到管控的，鎖頭為自身物件()

但此處每個Thread都各自生成物件執行程式，所以不具管控性，需調整程式為 => 生成一個執行物件，所有程序都使用同一物件

public static void main(String[] args) {
.
.
        List<Thread> threads = new ArrayList<>();
        TestRaceCondition runnable = new TestRaceCondition();
        for( int i=0 ; i < 10 ; i++) {
            Thread t1 = new Thread(runnable,"T"+i);
            threads.add(t1);
.
.

    @Override
    public synchronized void run() {
        for ( int i= 0  ; i < 1000 ;i ++){
            incrementCounter();
        }
    }

内容总结

以上是互联网集市为您收集整理的[Java] Thread -- 避免Race Condition (Synchronized)全部内容，希望文章能够帮你解决[Java] Thread -- 避免Race Condition (Synchronized)所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端