快捷導(dǎo)航

JAVA線程同步實(shí)例教程

更新時(shí)間：2014年08月27日 12:00:53 投稿：shichen2014

這篇文章主要介紹了JAVA線程同步實(shí)例教程,在Java程序設(shè)計(jì)中有著非常廣泛的應(yīng)用,需要的朋友可以參考下

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

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

一、未處理線程同步的一個(gè)例子：

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

輸出結(jié)果：

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

輸出結(jié)果：

t1是第1個(gè)執(zhí)行的線程。
t2是第2個(gè)執(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é)果是：