第八章線程-免費閱讀

　　

【正文】 if ((tick % 50000) == 0) { (Thread + num + , tick = + tick)。 } } 8. 3 線程的優先級 (續 ) —— 例 8_13 線程的優先級 70 class TestThread extends Thread{ private int tick = 1。 for (int i = 0。 public void stopme() { //在此方法中控制循環條件 flag=false。 ()。 //在售完最后一張票后， //設置一個結束標志， numbersize表示售票結束 } } 線程之間的通信 (續 ) —— 例 8_9 多線程編程基礎 49 class Producer extends Thread { Tickets t=null。} catch(Exception e){} (Producer puts ticket +(++number))。amp。將互斥方法放在共享的資源類 Tickets中 class Tickets { int size。amp。 public Producer(Tickets t) { =t。此時售票號小于存票數，且存票線程已經結束不再能將 置為 true，則售票線程陷入了死循環 ? 如果我們在 =false之前加上 sleep語句，讓售票線程多停留一會，則可以更加清楚地看到這個問題 if(i==) { try{ (1)。 int i=0。 //票號 int size。 } } 多線程編程基礎 線程間的數據共享 (續 ) —— 例 8_6 28 class SellTickets implements Runnable { private int tickets=200。 } public void run() { try { ( ().getName() + going to sleep for + sleepTime )。 public class Ex8_5 { public static void main( String [] args ) { TestThread threadobj = new TestThread()。 ( Threads started, main ends\n )。 (new thread ends)。 (new thread started,main thread ends )。 public TestThread( String name ) { super( name )。 TestThread thread2 = new TestThread( thread2 )。 } } ? 運行結果 main thread starts main thread ends new thread started The factorial of 10 is 3628800 new thread ends Thread類 (續 ) —— 例 8_1運行結果 多線程編程基礎 9 ? 結果說明 – main線程已經執行完后，新線程才執行完 – main函數調用 ()方法啟動新線程后并不等待其 run方法返回就繼續運行， 運行，不影響原來的 main函數的運行 ? 源程序修改 – 如果啟動新線程后希望主線程多持續一會再結束，可在start語句后加上讓當前線程（這里當然是 main）休息 1毫秒的語句： try { (1)。 public FactorialThread( int num ) { =num。這個子類應該重寫 Thread類的run方法，在 run方法中寫入需要在新線程中執行的語句段。 ()。 i=i1。 public final void stop() 停止線程運行，釋放該線程占用的對象鎖旗標。 // 啟動線程 2 ()。 ( getName() + finished } } Thread類 (續 ) —— 例 8_2 多線程編程基礎 16 ? 運行結果 Starting threads Threads started, main ends thread1 going to sleep for 3519 thread2 going to sleep for 1689 thread3 going to sleep for 5565 thread2 finished thread1 finished thread3 finished ? 說明 – 由于線程 3休眠時間最長，所以最后結束，線程 2休眠時間最短，所以最先結束 – 每次運行，都會產生不同的隨機休眠時間，所以結果都不相同 Thread類 (續 ) —— 例 8_2運行結果 多線程編程基礎 17 Runnable接口 ? Runnable接口 – Java多線程機制的一個重要部分，實際上它只有一個run()方法 – Thread類實現了 Runnable接口， 相對于 Thread類，它更適合于多個線程處理同一資源 – 實現 Runnable接口的類的對象可以用來創建線程，這時start方法啟動此線程就會在此線程上運行 run()方法 – 在編寫復雜程序時相關的類可能已經繼承了某個基類，而 Java不支持多繼承，在這種情況下，便需要通過實現Runnable接口來生成多線程 多線程編程基礎 18 ? 使用 Runnable接口實現例 8_1功能 public class Ex8_1{ public static void main( String [] args ) { (main thread starts)。 while(i0) { result=result*i。 new Thread(thread1,Thread1).start()。 } catch ( InterruptedException exception ) {}。 ( Threads started, main ends\n )。 new Thread(t).start()。 new Consumer(t).start()。 } public void run() { while( ) { (Producer puts ticket +(++))。 if(i==) =false。因此有些方法或程序段在同一時刻只能被一個線程執行，稱之為 監視區 – 協作：多個線程可以有條件地同時操作共享數據。 int i=0。 } } 多線程的同步控制 (續 ) —— synchronized關鍵字 多線程編程基礎 43 ? 說明 – 存票程序段和售票程序段為獲得同一對象的鎖旗標而實現互斥操作 – 當線程執行到 synchronized的時候，檢查傳入的實參對象，并申請得到該對象的鎖旗標。 } public synchronized void put() { //同步方法，實現存票的功能 (Producer puts ticket +(++number))。因此，需要使用線程同步與互斥技術，防止不同的線程同時對共享數據進行修改操作。 available=false。 } public void run() { while(=) ()。 new BufferedReader(new InputStreamReader()) .readLine()。默認情況下，每個線程的優先級都設置為 5 – 在線程 A運行過程中創建的新的線程對象 B，初始狀態具有和線程 A相同的優先級 – 如果 A是個后臺線程，則 B也是個后臺線程 – 可在線程創建之后的任何時候，通過 setPriority(int priority)方法改變其原來的優先級 線程的優先級 (續 ) 線程的優先級 67 ? 基于線程優先級的線程調度 – 具有較高優先級的線程比優先級較低的線程優先執行 – 對具有相同優先級的線程， Java的處理是隨機的 – 底層操作系統支持的優先級可能要少于 10個，這樣會造成一些混亂。 //設置第二個線程優先級為 3 for (int i = 0。 yield()。}catch(Exception e){}。 } public void run() { while (tick 400000) { tick++。 runners[0].setPriority(2)。 //如果 flag為真則一直顯示遞增整數 } } } ? 運行效果為按下回車鍵后則停止顯示 控制線程的生命 (續 ) —— 例 8_12 線程的生命周期 65 線程的優先級 ? 線程調度 – 在單 CPU的系統中，多個線程需要共享 CPU，在任何時間點上實際只能有一個線程在運行 – 控制多個線程在同一個 CPU上以某種順序運行稱為線程調度 – Java虛擬機支持一種非常簡單的、確定的調度算法，叫做固定優先級算法。 public class Ex8_12{ public static void main(String[] args) throws IOException{ TestThread t=new TestThread()。 } } class Consumer extends Thread { Tickets t=nul