JAVA--線程同步

2019-11-14 21:00:18

字體：大中小

來源：轉載

供稿：網友

java--線程同步

　　繼昨天線程介紹后，今天我又把線程中的同步問題總結了一下，現在就和大家一起探討一下。

　　線程加鎖有什么用處呢？舉個例子：比如你現在有30000塊大洋在銀行存著，現在你到銀行取錢，當你輸入密碼完成后，已經輸入取款金額，比如你輸入的是20000，就是在銀行給你拿錢這個時刻，你老婆也去銀行取這筆錢，你老婆同樣取20000，因為此時你的賬上仍然是30000，所以銀行同樣的操作在你老婆那端有進行了一遍，這樣當你們兩個完成各自操作后，銀行記錄的你賬上還應該有10000塊存款，這樣是不是很爽。解決這個問題就用到了線程加鎖的知識，下面就讓我們一起來學習一下吧。

一、未處理線程同步的一個例子：

public class TextSync implements Runnable{    /**未處理線程同步     * @param args     */    Time time = new Time();    public static void main(String[] args) {        TextSync text = new TextSync();        Thread t1 = new Thread(text);        Thread t2 = new Thread(text);        t1.setName("t1");        t2.setName("t2");        t1.start();        t2.start();    }    @Override    public void run() {        time.add(Thread.currentThread().getName());    }}class Time {    PRivate static int num = 0;    public void add(String name){        try {            num++;            //當第一個線程執行到此時，num變成了1，第一個線程暫停一秒，            //第二個線程開始執行，當第二個線程執行到此時，num變成了2，第二個線程暫停一秒，            //第一個線程此時的num同樣變成了2，所以最終的結果均為2；            Thread.sleep(1000);        } catch (InterruptedException e) {            e.printStackTrace();        }        System.out.println(name+"是第"+num+"個執行的線程。");    }}

輸出結果：

二、線程同步

public class TextSynctwo implements Runnable{    /**線程同步     * @param args     */    Time1 time = new Time1();    public static void main(String[] args) {        TextSynctwo text = new TextSynctwo();        Thread t1 = new Thread(text);        Thread t2 = new Thread(text);        t1.setName("t1");        t2.setName("t2");        t1.start();        t2.start();    }    @Override    public void run() {        time.add(Thread.currentThread().getName());    }}class Time1 {    private static int num = 0;        //synchronized鎖定當前線程，可以在方法定義時進行聲明，或采用在方法中進行設置。    public synchronized void add(String name){        //synchronized (this) {//鎖定當前線程，防止此時被別的線程執行            try {                num++;                Thread.sleep(1000);            } catch (InterruptedException e) {                e.printStackTrace();            }            System.out.println(name+"是第"+num+"個執行的線程。");        //}    }}

輸出結果：

三、死鎖

public class TestDeadLock implements Runnable{    /**死鎖     * @param args     */    private int flag = 0 ;     static Object o1 = new Object();    static Object o2 = new Object();    public static void main(String[] args) {        TestDeadLock td1 = new TestDeadLock();         TestDeadLock td2 = new TestDeadLock();         td1.flag = 1;        td2.flag = 2;        Thread t1 = new Thread(td1);         Thread t2 = new Thread(td2);        t1.setName("t1");        t2.setName("t2");        t1.start();        t2.start();    }    @Override    public void run() {        System.out.println(Thread.currentThread().getName());        if(flag == 1){            synchronized(o1){                try {                    Thread.sleep(5000);                } catch (InterruptedException e) {                    e.printStackTrace();                }                synchronized(o2){                    System.out.println("1");                }            }        }        if(flag == 2){            synchronized(o2){                try {                    Thread.sleep(5000);                } catch (InterruptedException e) {                    e.printStackTrace();                }                synchronized(o1){                    System.out.println("2");                }            }        }    }}

四、鎖定

public class TT implements Runnable{    /**鎖定     * @param args     */    int b = 100;    public static void main(String[] args) {        TT tt = new TT();        Thread th = new Thread(tt);        th.start();        try {            tt.m2();        } catch (Exception e) {            e.printStackTrace();        }        System.out.println(tt.b);    }    @Override    public void run() {        try {            m1();        } catch (Exception e) {            e.printStackTrace();        }    }        private synchronized void m1() throws Exception{        b = 1000;        Thread.sleep(5000);        System.out.println("b="+b);    }    private synchronized void m2() throws Exception{        Thread.sleep(2500);        b = 2500;    } }

對于鎖定這個我有一個疑問，還望大神們給予指點，現在的輸出結果：