掛起和恢復線程
Thread 的API中包含兩個被淘汰的方法，它們用于臨時掛起和重啟某個線程，這些方法已經被淘汰，因為它們是不安全的，不穩定的。如果在不合適的時候掛起線程（比如，鎖定共享資源時），此時便可能會發生死鎖條件——其他線程在等待該線程釋放鎖，但該線程卻被掛起了，便會發生死鎖。另外，在長時間計算期間掛起線程也可能導致問題。
下面的代碼演示了通過休眠來延緩運行，模擬長時間運行的情況，使線程更可能在不適當的時候被掛起：
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）。
下面我們給出不用上述兩個方法來實現線程掛起和恢復的策略——設置標志位。通過該方法實現線程的掛起和恢復有一個很好的地方，就是可以在線程的指定位置實現線程的掛起和恢復，而不用擔心其不確定性。
對于上述代碼的改進代碼如下：
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 并發編程之線程掛起、恢復與終止，希望對大家有所幫助，如果大家有任何疑問請給我留言，小編會及時回復大家的。在此也非常感謝大家對億速云網站的支持！
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
