JAVA線程同步實例教程

2019-11-26 15:26:56

字體：大中小

供稿：網(wǎng)友

線程是Java程序設(shè)計里非常重要的概念，本文就以實例形式對此加以詳細(xì)解讀。具體分析如下：

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

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

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++;      //當(dāng)?shù)谝粋€線程執(zhí)行到此時，num變成了1，第一個線程暫停一秒，      //第二個線程開始執(zhí)行，當(dāng)?shù)诙€線程執(zhí)行到此時，num變成了2，第二個線程暫停一秒，      //第一個線程此時的num同樣變成了2，所以最終的結(jié)果均為2；      Thread.sleep(1000);    } catch (InterruptedException e) {      e.printStackTrace();    }    System.out.println(name+"是第"+num+"個執(zhí)行的線程。");  }}

輸出結(jié)果：

t2是第2個執(zhí)行的線程。t1是第2個執(zhí)行的線程。

二、線程同步

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鎖定當(dāng)前線程，可以在方法定義時進(jìn)行聲明，或采用在方法中進(jìn)行設(shè)置。  public synchronized void add(String name){    //synchronized (this) {//鎖定當(dāng)前線程，防止此時被別的線程執(zhí)行      try {        num++;        Thread.sleep(1000);      } catch (InterruptedException e) {        e.printStackTrace();      }      System.out.println(name+"是第"+num+"個執(zhí)行的線程。");    //}  }}

輸出結(jié)果：

t1是第1個執(zhí)行的線程。t2是第2個執(zhí)行的線程。

三、死鎖

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;  } }

現(xiàn)在的輸出結(jié)果是：