前面介紹了線程的基本用法,按理說足夠一般的場合使用了,只是每次開闢新線程,都得單獨定義專門的線程類,著實開銷不小。註意到新線程內部真正需要開發者重寫的僅有run方法,其實就是一段代碼塊,分線程啟動之後也單單執行該代碼段而已。因而完全可以把這段代碼抽出來,把它定義為類似方法的一串任務代碼,這樣能夠像調 ...
前面介紹了線程的基本用法,按理說足夠一般的場合使用了,只是每次開闢新線程,都得單獨定義專門的線程類,著實開銷不小。註意到新線程內部真正需要開發者重寫的僅有run方法,其實就是一段代碼塊,分線程啟動之後也單單執行該代碼段而已。因而完全可以把這段代碼抽出來,把它定義為類似方法的一串任務代碼,這樣能夠像調用公共方法一樣多次調用這段代碼,也就無需另外定義新的線程類,只需命令已有的Thread去執行該代碼段就好了。
在Java中定義某個代碼段,則要藉助於介面Runnable,它是個函數式介面,唯一需要實現的只有run方法。之所以定義成函數式介面的形式,是因為要給任務方法套上面向對象的殼,這樣才好由外部去調用封裝好的任務對象。現在有個階乘運算的任務,希望開個分線程計算式子“10!”的結果,那便定義一個實現了Runnable介面的任務類FactorialTask,並重寫run方法補充求解“10!”的代碼邏輯。編寫完成的FactorialTask類代碼示例如下:
// 定義一個求階乘的任務 private static class FactorialTask implements Runnable { @Override public void run() { int product = 1; for (int i=1; i<=10; i++) { product *= i; } PrintUtils.print(Thread.currentThread().getName(), "階乘結果="+product); } }
接著創建FactorialTask類的任務對象,並通過線程類的構造方法傳入該任務,這就實現了在分線程中啟動階乘任務的功能。下麵是外部給階乘任務開啟新線程的代碼例子:
// 通過Runnable創建線程的第一種方式:傳入普通實例 FactorialTask task = new FactorialTask(); new Thread(task).start(); // 創建並啟動線程
鑒於階乘任務的實現代碼很短,似無必要定義專門的任務類,不妨循著比較器Comparator的舊例,採取匿名內部類的方式書寫更為便捷。於是可線上程類Thread的構造方法中直接填入實現後的Runnable任務代碼,具體的調用代碼如下所示:
// 通過Runnable創建線程的第二種方式:傳入匿名內部類的實例 new Thread(new Runnable() { @Override public void run() { int product = 1; for (int i=1; i<=10; i++) { product *= i; } PrintUtils.print(Thread.currentThread().getName(), "階乘結果="+product); } }).start(); // 創建並啟動線程
由於Runnable是函數式介面,因此完全可以使用Lambda表達式加以簡化,下麵便是利用Lambda表達式取代匿名內部類的任務線程代碼:
// 通過Runnable創建線程的第三種方式:使用Lambda表達式 new Thread(() -> { int product = 1; for (int i=1; i<=10; i++) { product *= i; } PrintUtils.print(Thread.currentThread().getName(), "階乘結果="+product); }).start(); // 創建並啟動線程
雖說Runnable介面的花樣會比直接從Thread派生的多一些,但Runnable方式依舊要求實現run方法,看起來像是換湯不換藥,感覺即使沒有Runnable也不影響線程的運用,最多在編碼上有點繁瑣罷了。可事情沒這麼簡單,要知道引入線程的目的是為了加快處理速度,多個線程同時運行的話,必然涉及到資源共用及其合理分配。比如火車站賣動車票,只有一個售票視窗賣票的話,明顯賣得慢,肯定要多開幾個售票視窗,一起賣票才賣得快。假設目前還剩一百張動車票,此時開了三個售票視窗,這樣等同於啟動了三個售票線程,每個線程都在賣剩下的一百張票。倘若不採取Runnable介面,而是直接定義新線程的話,售票線程的定義代碼應該類似下麵這般:
// 單獨定義一個售票線程 private static class TicketThread extends Thread { private int ticketCount = 100; // 可出售的車票數量 public TicketThread(String name) { setName(name); // 設置當前線程的名稱 } @Override public void run() { while (ticketCount > 0) { // 還有餘票可供出售 ticketCount--; // 餘票數量減一 // 以下列印售票日誌,包括售票時間、售票線程、當前餘票等信息 String left = String.format("當前餘票為%d張", ticketCount); PrintUtils.print(Thread.currentThread().getName(), left); } } }
然後分別創建並啟動三個售票線程,就像以下代碼所示的那樣:
//創建多個線程分別啟動,三個線程每個各賣100張,總共賣了300張票 new TicketThread("售票線程A").start(); new TicketThread("售票線程B").start(); new TicketThread("售票線程C").start();
猜猜看,上面三個售票線程總共賣了多少張票,實地運行測試代碼後發現,這三個線程竟然賣掉了三百張票,而不是期望的一百張餘票。究其原因,乃是各線程售賣的車票為專享而非共用,每個線程只認可自己掌握的車票,不認可其它線程的車票,結果導致三個線程各賣各的,加起來一共賣了三百張票。所以單獨定義的線程類處理獨立的事務倒還湊合,要是處理共用的事務就難辦了。
如果採用Runnable介面來定義售票任務,就可以很方便地進行資源共用,只要命令三個線程同時執行售票任務即可。下麵是開啟三個線程運行售票任務的代碼例子:
//只創建一個售票任務,並啟動三個線程一起執行售票任務,總共賣了100張票 Runnable seller = new Runnable() { private int ticketCount = 100; // 可出售的車票數量 @Override public void run() { while (ticketCount > 0) { // 還有餘票可供出售 ticketCount--; // 餘票數量減一 // 以下列印售票日誌,包括售票時間、售票線程、當前餘票等信息 String left = String.format("當前餘票為%d張", ticketCount); PrintUtils.print(Thread.currentThread().getName(), left); } } }; new Thread(seller, "售票線程A").start(); // 啟動售票線程A new Thread(seller, "售票線程B").start(); // 啟動售票線程B new Thread(seller, "售票線程C").start(); // 啟動售票線程C
因為100張餘票位於同一個售票任務seller裡面,所以這些車票理應為執行任務的線程們所共用。運行上述的任務測試代碼,觀察到如下的線程工作日誌:
16:27:21.077 售票線程C 當前餘票為98張 16:27:21.083 售票線程A 當前餘票為96張 16:27:21.083 售票線程C 當前餘票為95張 16:27:21.077 售票線程B 當前餘票為97張 ………………………這裡省略中間的日誌…………………… 16:27:21.118 售票線程B 當前餘票為2張 16:27:21.118 售票線程A 當前餘票為1張 16:27:21.118 售票線程C 當前餘票為4張 16:27:21.118 售票線程B 當前餘票為0張
可見此時三個售票線程一共賣掉了100張車票,才符合多視窗同時售票的預期功能。
更多Java技術文章參見《Java開發筆記(序)章節目錄》