引言

現有一個需求如下：

有10000張火車票，每張票都有一個編號，同時有10個窗口對外售票，如何確保車票的正常售賣？

程序一：使用List

問題的解決辦法都是從我們最最熟悉的角度思考。程序一，我們使用一個普通的List作為方案。

閱讀以下代碼，觀察執行結果：

public class TicketSell_01 {static List<String> tickets = new ArrayList<>();static {for (int i = 0; i < 10000; i++)tickets.add("票編號： " + i);}public static void main(String[] args) {for (int i = 0; i < 10; i++) {new Thread(() -> {while (tickets.size() > 0) {System.out.println("銷售了--" + tickets.remove(0));}}).start();}} }

輸出結果如下，可以看到，編號0的車票被銷售了兩次。List不是同步容器，容器內的remove()等方法都無法做到原子性，因此會出現重復售票的問題，因此是不安全的：

程序二：使用Vector

以Vector代替List作為容器。區別是，Vector是同步容器，內部的方法都是同步的。但是下面的代碼依然會存在問題。

雖然size()方法和remove()方法本身是原子性的，其他線程無法打斷，但是在判斷size和remove之間的部分依然會有線程交叉執行的可能，這樣，雖然可以解決重復銷售的問題，但是依然會導致：ArrayIndexOutOfBoundsException

public class TicketSell_02 {static Vector<String> tickets = new Vector<>();static {for (int i = 0; i < 10000; i++)tickets.add("票編號： " + i);}public static void main(String[] args) {for (int i = 0; i < 10; i++) {new Thread(() -> {while (tickets.size() > 0) {try {TimeUnit.MILLISECONDS.sleep(5);} catch (Exception e) {e.printStackTrace();}System.out.println("銷售了--" + tickets.remove(0));}}).start();}} }

執行結果：

程序三：同步

使用synchronized進行線程同步，可以有效解決邏輯問題，但是很明顯，這種方法的缺點就是效率低下。

public class TicketSell_03 {static List<String> tickets = new LinkedList<>();static {for (int i = 0; i < 10000; i++)tickets.add("票編號： " + i);}public static void main(String[] args) {for (int i = 0; i < 10; i++) {new Thread(() -> {while (true) {synchronized (tickets) {if (tickets.size() == 0)break;System.out.println("銷售了票--" + tickets.remove(0));}}}).start();}} }

程序四：并發容器Queue

ConcurrentLinkedQueue是一個并發隊列。但凡并發容器，其內部的方法都保證是原子性的。下面的代碼中poll()表示從隊列的頭部獲得一個數據，當返回值為null時，代表這個隊列已經沒有值了。因為隊列本身不允許存null值，否則會報空指針異常，因此當返回值為null時，一定表示隊列已空（size() == 0）。隊列的底層是使用一個叫做CompareAndSet（CAS）的技術實現的，不是加鎖的實現，因此在高并發的情況下依然可以擁有很高的效率。

public class TicketSell_04 {static Queue<String> tickets = new ConcurrentLinkedQueue<>();static {for (int i = 0; i < 10000; i++)tickets.add("票編號： " + i);}public static void main(String[] args) {for (int i = 0; i < 10; i++) {new Thread(() -> {while (true) {String s = tickets.poll();if (s == null)break;elseSystem.out.println("銷售了--" + s);}}).start();}} }

?

總結

以上是生活随笔為你收集整理的Java并发编程实战————售票问题的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。