Thread 的API中包含兩個被淘汰的方法，它們用于臨時掛起和重啟某個線程，這些方法已經被淘汰，因為它們是不安全的，不穩定的。如果在不合適的時候掛起線程（比如，鎖定共享資源時），此時便可能會發生死鎖條件——其他線程在等待該線程釋放鎖，但該線程卻被掛起了，便會發生死鎖。另外，在長時間計算期間掛起線程也可能導致問題。
下面的代碼演示了通過休眠來延緩運行，模擬長時間運行的情況，使線程更可能在不適當的時候被掛起：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
|
public class DeprecatedSuspendResume extends Object implements Runnable{ //volatile關鍵字，表示該變量可能在被一個線程使用的同時，被另一個線程修改 private volatile int firstVal; private volatile int secondVal; //判斷二者是否相等 public boolean areValuesEqual(){ return ( firstVal == secondVal); } public void run() { try{ firstVal = 0; secondVal = 0; workMethod(); }catch(InterruptedException x){ System.out.println("interrupted while in workMethod()"); } } private void workMethod() throws InterruptedException { int val = 1; while (true){ stepOne(val); stepTwo(val); val++; Thread.sleep(200); //再次循環錢休眠200毫秒 } } //賦值后，休眠300毫秒，從而使線程有機會在stepOne操作和stepTwo操作之間被掛起 private void stepOne(int newVal) throws InterruptedException{ firstVal = newVal; Thread.sleep(300); //模擬長時間運行的情況 } private void stepTwo(int newVal){ secondVal = newVal; } public static void main(String[] args){ DeprecatedSuspendResume dsr = new DeprecatedSuspendResume(); Thread t = new Thread(dsr); t.start(); //休眠1秒，讓其他線程有機會獲得執行 try { Thread.sleep(1000);} catch(InterruptedException x){} for (int i = 0; i < 10; i++){ //掛起線程 t.suspend(); System.out.println("dsr.areValuesEqual()=" + dsr.areValuesEqual()); //恢復線程 t.resume(); try{ //線程隨機休眠0~2秒 Thread.sleep((long)(Math.random()*2000.0)); }catch(InterruptedException x){ //略 } } System.exit(0); //中斷應用程序 } } |
某次運行結果如下：
從areValuesEqual（）返回的值有時為true，有時為false。以上代碼中，在設置firstVal之后，但在設置secondVal之前，掛起新線程會產生麻煩，此時輸出的結果會為false（情況1），這段時間不適宜掛起線程，但因為線程不能控制何時調用它的suspend方法，所以這種情況是不可避免的。
當然，即使線程不被掛起（注釋掉掛起和恢復線程的兩行代碼），如果在main線程中執行asr.areValuesEqual（）進行比較時，恰逢stepOne操作執行完，而stepTwo操作還沒執行，那么得到的結果同樣可能是false（情況2）。
下面我們給出不用上述兩個方法來實現線程掛起和恢復的策略——設置標志位。通過該方法實現線程的掛起和恢復有一個很好的地方，就是可以在線程的指定位置實現線程的掛起和恢復，而不用擔心其不確定性。
對于上述代碼的改進代碼如下：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
|
public class AlternateSuspendResume extends Object implements Runnable { private volatile int firstVal; private volatile int secondVal; //增加標志位，用來實現線程的掛起和恢復 private volatile boolean suspended; public boolean areValuesEqual() { return ( firstVal == secondVal ); } public void run() { try { suspended = false; firstVal = 0; secondVal = 0; workMethod(); } catch ( InterruptedException x ) { System.out.println("interrupted while in workMethod()"); } } private void workMethod() throws InterruptedException { int val = 1; while ( true ) { //僅當賢臣掛起時，才運行這行代碼 waitWhileSuspended(); stepOne(val); stepTwo(val); val++; //僅當線程掛起時，才運行這行代碼 waitWhileSuspended(); Thread.sleep(200); } } private void stepOne(int newVal) throws InterruptedException { firstVal = newVal; Thread.sleep(300); } private void stepTwo(int newVal) { secondVal = newVal; } public void suspendRequest() { suspended = true; } public void resumeRequest() { suspended = false; } private void waitWhileSuspended() throws InterruptedException { //這是一個“繁忙等待”技術的示例。 //它是非等待條件改變的最佳途徑，因為它會不斷請求處理器周期地執行檢查， //更佳的技術是：使用Java的內置“通知-等待”機制 while ( suspended ) { Thread.sleep(200); } } public static void main(String[] args) { AlternateSuspendResume asr = new AlternateSuspendResume(); Thread t = new Thread(asr); t.start(); //休眠1秒，讓其他線程有機會獲得執行 try { Thread.sleep(1000); } catch ( InterruptedException x ) { } for ( int i = 0; i < 10; i++ ) { asr.suspendRequest(); //讓線程有機會注意到掛起請求 //注意：這里休眠時間一定要大于 //stepOne操作對firstVal賦值后的休眠時間，即300ms， //目的是為了防止在執行asr.areValuesEqual（）進行比較時, //恰逢stepOne操作執行完，而stepTwo操作還沒執行 try { Thread.sleep(350); } catch ( InterruptedException x ) { } System.out.println("dsr.areValuesEqual()=" + asr.areValuesEqual()); asr.resumeRequest(); try { //線程隨機休眠0~2秒 Thread.sleep( ( long ) (Math.random() * 2000.0) ); } catch ( InterruptedException x ) { //略 } } System.exit(0); //退出應用程序 } } |
運行結果如下：
線程掛起的位置不確定main線程中執行asr.areValuesEqual（）進行比較時，恰逢stepOne操作執行完，而stepTwo操作還沒執行）asr.areValuesEqual（）操作前，讓main線程休眠450ms（>300ms），如果掛起請求發出時，新線程正執行到或即將執行到stepOne操作（如果在其前面的話，就會響應掛起請求，從而掛起線程），那么在stepTwo操作執行前，main線程的休眠還沒結束，從而main線程休眠結束后執行asr.areValuesEqual（）操作進行比較時，stepTwo操作已經執行完，因此也不會出現輸出結果為false的情況。
可以將ars.suspendRequest（）代碼后的sleep代碼去掉，或將休眠時間改為200（明顯小于300即可）后，查看執行結果，會發現結果中依然會有出現false的情況。如下圖所示：
總結：線程的掛起和恢復實現的正確方法是：通過設置標志位，讓線程在安全的位置掛起
終止線程
終止線程的替代方法：同樣是使用標志位，通過控制標志位來終止線程。
以上所述是小編給大家介紹的Java 并發編程之線程掛起、恢復與終止，希望對大家有所幫助，如果大家有任何疑問請給我留言，小編會及時回復大家的。在此也非常感謝大家對服務器之家網站的支持！
原文鏈接：http://www.cnblogs.com/web424/p/6807319.html
