引言

現(xiàn)有一個需求如下：

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

程序一：使用List

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

閱讀以下代碼，觀察執(zhí)行結(jié)果：

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

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

程序二：使用Vector

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

雖然size()方法和remove()方法本身是原子性的，其他線程無法打斷，但是在判斷size和remove之間的部分依然會有線程交叉執(zhí)行的可能，這樣，雖然可以解決重復(fù)銷售的問題，但是依然會導(dǎo)致：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();}} }

執(zhí)行結(jié)果：

程序三：同步

使用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();}} }

程序四：并發(fā)容器Queue

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

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

?

總結(jié)

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

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。