<rt id="bn8ez"></rt>
<label id="bn8ez"></label>

  • <span id="bn8ez"></span>

    <label id="bn8ez"><meter id="bn8ez"></meter></label>

    tbwshc

    Java線程:線程的同步-同步方法

     線程的同步是保證多線程安全訪問競爭資源的一種手段。
        線程的同步是Java多線程編程的難點,往往開發者搞不清楚什么是競爭資源、什么時候需要考慮同步,怎么同步等等問題,當然,這些問題沒有很明確的答案,但有些原則問題需要考慮,是否有競爭資源被同時改動的問題?
     
        在本文之前,請參閱《Java線程:線程的同步與鎖》,本文是在此基礎上所寫的。
     
        對于同步,在具體的Java代碼中需要完成一下兩個操作:
        把競爭訪問的資源標識為private;
        同步哪些修改變量的代碼,使用synchronized關鍵字同步方法或代碼。
        當然這不是唯一控制并發安全的途徑。
     
        synchronized關鍵字使用說明
        synchronized只能標記非抽象的方法,不能標識成員變量。
     
        為了演示同步方法的使用,構建了一個信用卡賬戶,起初信用額為100w,然后模擬透支、存款等多個操作。顯然銀行賬戶User對象是個競爭資源,而多個并發操作的是賬戶方法oper(int x),當然應該在此方法上加上同步,并將賬戶的余額設為私有變量,禁止直接訪問。
     
     
    /**
    * Java線程:線程的同步
    *
    * @author leizhimin 2009-11-4 11:23:32
    */

    public class Test {
            public static void main(String[] args) {
                    User u = new User("張三", 100);
                    MyThread t1 = new MyThread("線程A", u, 20);
                    MyThread t2 = new MyThread("線程B", u, -60);
                    MyThread t3 = new MyThread("線程C", u, -80);
                    MyThread t4 = new MyThread("線程D", u, -30);
                    MyThread t5 = new MyThread("線程E", u, 32);
                    MyThread t6 = new MyThread("線程F", u, 21);

                    t1.start();
                    t2.start();
                    t3.start();
                    t4.start();
                    t5.start();
                    t6.start();
            }
    }

    class MyThread extends Thread {
            private User u;
            private int y = 0;

            MyThread(String name, User u, int y) {
                    super(name);
                    this.u = u;
                    this.y = y;
            }

            public void run() {
                    u.oper(y);
            }
    }

    class User {
            private String code;
            private int cash;

            User(String code, int cash) {
                    this.code = code;
                    this.cash = cash;
            }

            public String getCode() {
                    return code;
            }

            public void setCode(String code) {
                    this.code = code;
            }

            /**
             * 業務方法
             * @param x 添加x萬元
             */

            public synchronized void oper(int x) {
                    try {
                            Thread.sleep(10L);
                            this.cash += x;
                            System.out.println(Thread.currentThread().getName() + "運行結束,增加“" + x + "”,當前用戶賬戶余額為:" + cash);
                            Thread.sleep(10L);
                    } catch (InterruptedException e) {
                            e.printStackTrace();
                    }
            }

            @Override
            public String toString() {
                    return "User{" +
                                    "code='" + code + '\'' +
                                    ", cash=" + cash +
                                    '}';
            }
    }
     
        輸出結果:
    線程A運行結束,增加“20”,當前用戶賬戶余額為:120
    線程F運行結束,增加“21”,當前用戶賬戶余額為:141
    線程E運行結束,增加“32”,當前用戶賬戶余額為:173
    線程C運行結束,增加“-80”,當前用戶賬戶余額為:93
    線程B運行結束,增加“-60”,當前用戶賬戶余額為:33
    線程D運行結束,增加“-30”,當前用戶賬戶余額為:3

    Process finished with exit code 0
     
     
        反面教材,不同步的情況,也就是去掉oper(int x)方法的synchronized修飾符,然后運行程序,結果如下:
    線程A運行結束,增加“20”,當前用戶賬戶余額為:61
    線程D運行結束,增加“-30”,當前用戶賬戶余額為:63
    線程B運行結束,增加“-60”,當前用戶賬戶余額為:3
    線程F運行結束,增加“21”,當前用戶賬戶余額為:61
    線程E運行結束,增加“32”,當前用戶賬戶余額為:93
    線程C運行結束,增加“-80”,當前用戶賬戶余額為:61

    Process finished with exit code 0
     
        很顯然,上面的結果是錯誤的,導致錯誤的原因是多個線程并發訪問了競爭資源u,tb并對u的屬性做了改動。
     
        可見同步的重要性。
     
     
        注意:
        通過前文可知,線程退出同步方法時將釋放掉方法所屬對象的鎖,但還應該注意的是,同步方法中還可以使用特定的方法對線程進行調度。這些方法來自于java.lang.Object類。
     
    void notify()    
                        喚醒在此對象監視器上等待的單個線程。    
    void notifyAll()    
                        喚醒在此對象監視器上等待的所有線程。    
    void wait()    
                        導致當前的線程等待,直到其他線程調用此對象的 notify() 方法或 notifyAll() 方法。    
    void wait(long timeout)    
                        導致當前的線程等待,直到其他線程調用此對象的 notify() 方法或 notifyAll() 方法,或者超過指定的時間量。    
    void wait(long timeout, int nanos)    
                        導致當前的線程等待,直到其他線程調用此對象的 notify() 方法或 notifyAll() 方法,或者其他某個線程中斷當前線程,或者已超過某個實際時間量。
     
        結合以上方法,處理多線程同步與互斥問題非常重要,著名的生產者-消費者例子就是一個經典的例子,任何語言多線程必學的例子。

    posted on 2012-08-09 11:40 chen11-1 閱讀(1202) 評論(0)  編輯  收藏


    只有注冊用戶登錄后才能發表評論。


    網站導航:
     
    主站蜘蛛池模板: 免费一级e一片在线播放| 国产免费AV片无码永久免费| 亚洲最大AV网站在线观看| 狼人大香伊蕉国产WWW亚洲| 免费观看a级毛片| 国产成人亚洲精品播放器下载 | 成全高清在线观看免费| 亚洲日产无码中文字幕| 精品在线免费观看| 久久精品亚洲精品国产色婷| 97av免费视频| 亚洲国产成人精品激情| 日韩在线免费看网站| 精品女同一区二区三区免费播放| 日本中文一区二区三区亚洲| 中文毛片无遮挡高清免费| 亚洲日本中文字幕区| 114一级毛片免费| 亚洲爆乳成av人在线视菜奈实| 国产国产人免费人成免费视频| 特级毛片在线大全免费播放| 亚洲乱码精品久久久久..| 无码av免费网站| 亚洲人成网站18禁止| 亚洲精品无码永久在线观看| 国产一区二区免费视频| 亚洲成aⅴ人在线观看| 国产公开免费人成视频 | 免费在线观影网站| 亚洲精品中文字幕麻豆| 日韩免费电影在线观看| 久草免费福利在线| 亚洲日本国产乱码va在线观看| 日本一道一区二区免费看| 久久久久久久国产免费看| 亚洲不卡视频在线观看| 亚洲国产中文字幕在线观看| 精品免费视在线观看| 国产精品观看在线亚洲人成网| 亚洲av日韩综合一区在线观看| 成人一a毛片免费视频|