Java多線程之併發安全經典案例-賣票

#線程相關知識
1.建立線程的兩種方式java

  • 繼承Thread類。
  • 實現Runnable接口。(這種方式較爲經常使用)

2.實現Runnable接口的好處安全

  • 將線程的任務從線程的子類中分離出來,進行了單獨的封裝。按照面向對象的思想將任務的封裝成對象。
  • 避免了java單繼承的侷限性。

#多線程併發安全之賣票多線程

  • 代碼
/** * Created by yuandl on 2016-09-30. */
public class RunnableTest implements Runnable {
    private int tick = 60;

    @Override
    public void run() {
        while (true) {
                if (tick == 0) {
                    break;
                }
                try {
                    Thread.sleep(10);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println(Thread.currentThread().getName() + "=========" + tick--);
        }
    }
    public static void main(String[] args) {
        RunnableTest runnableTest=new RunnableTest();
        new Thread(runnableTest).start();
        new Thread(runnableTest).start();


    }
}複製代碼
  • 打印結果併發

    Thread-1=========11
    Thread-1=========10
    Thread-0=========9
    Thread-1=========8
    Thread-0=========7
    Thread-0=========6
    Thread-1=========5
    Thread-0=========4
    Thread-1=========3
    Thread-0=========2
    Thread-1=========1
    Thread-0=========0
    Thread-0=========-1
    Thread-0=========-2
    Thread-0=========-3ide

  • 發現問題,賣票居然出現了負數,這確定是有問題的this

  • 線程安全問題產生的緣由:
    • 多個線程在操做共享的數據。
    • 操做共享數據的線程代碼有多條。
    • 當一個線程在執行操做共享數據的多條代碼過程當中,其餘線程參與了運算。就會致使線程安全問題的產生。
  • 解決思路:
    • 就是將多條操做共享數據的線程代碼封裝起來,當有線程在執行這些代碼的時候,其餘線程時不能夠參與運算的。必需要當前線程把這些代碼都執行完畢後,其餘線程才能夠參與運算。在java中,用同步代碼塊就能夠解決這個問題。
  • 同步代碼塊的格式spa

    synchronized(對象)
    {
    須要被同步的代碼 ;
    }線程

  • 同步的好處:解決了線程的安全問題。code

  • 同步的弊端:相對下降了效率,由於同步外的線程的都會判斷同步鎖。
  • 同步的前提:同步中必須有多個線程並使用同一個鎖。對象

    #最終線程安全同步的代碼

/** * Created by yuandl on 2016-09-30. */
public class RunnableTest implements Runnable {
    private int tick = 60;

    @Override
    public void run() {
        while (true) {
            synchronized (this) {
                if (tick == 0) {
                    break;
                }
                try {
                    Thread.sleep(10);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println(Thread.currentThread().getName() + "=========" + tick--);
            }
        }
    }
    public static void main(String[] args) {
        RunnableTest runnableTest=new RunnableTest();
        new Thread(runnableTest).start();
        new Thread(runnableTest).start();
    }
}複製代碼
  • 執行結果

    Thread-1=========10
    Thread-1=========9
    Thread-1=========8
    Thread-1=========7
    Thread-1=========6
    Thread-1=========5
    Thread-1=========4
    Thread-1=========3
    Thread-1=========2
    Thread-1=========1

Process finished with exit code 0

完美解決以上問題

相關文章
相關標籤/搜索