快捷導(dǎo)航

Java實(shí)現(xiàn)線程的暫停和恢復(fù)的示例詳解

更新時(shí)間：2023年11月22日 11:57:37 作者：桃花鍵神

這幾天的項(xiàng)目中,客戶給了個(gè)需求,希望我可以開(kāi)啟一個(gè)任務(wù),想什么時(shí)候暫停就什么時(shí)候暫停,想什么時(shí)候開(kāi)始就什么時(shí)候開(kāi)始,所以本文小編給大家介紹了Java實(shí)現(xiàn)線程的暫停和恢復(fù)的示例,需要的朋友可以參考下

問(wèn)題思路

在Java中，線程的暫停和恢復(fù)可以通過(guò)Thread類(lèi)的interrupt方法實(shí)現(xiàn)。需要注意的是，interrupt方法并不會(huì)立即停止線程，而是會(huì)設(shè)置一個(gè)中斷標(biāo)記，你需要在你的線程中適當(dāng)?shù)仨憫?yīng)這個(gè)中斷。

以下是一個(gè)簡(jiǎn)單的示例：

問(wèn)題答案

public class MyThread extends Thread {  
    private volatile boolean isInterrupted = false;  
  
    @Override  
    public void run() {  
        while (!isInterrupted) {  
            // 線程正在執(zhí)行的任務(wù)...  
        }  
    }  
  
    public void interruptThread() {  
        isInterrupted = true;  
    }  
  
    public void resetInterrupt() {  
        isInterrupted = false;  
    }  
}

在這個(gè)例子中，我們創(chuàng)建了一個(gè)繼承自Thread的類(lèi)，并添加了一個(gè)isInterrupted標(biāo)志來(lái)跟蹤線程是否被中斷。在run方法中，我們檢查這個(gè)標(biāo)志，如果它被設(shè)置為true，那么我們就退出循環(huán)，線程就會(huì)結(jié)束。

你可以通過(guò)調(diào)用interruptThread方法來(lái)中斷線程，并通過(guò)調(diào)用resetInterrupt方法來(lái)重置中斷狀態(tài)。需要注意的是，當(dāng)線程被中斷時(shí)，它會(huì)拋出InterruptedException，你需要在你的代碼中處理這個(gè)異常。

其他方法

自定義線程類(lèi)（MyThread）

package com.example.wangjun.myapplication;

import android.util.Log;

public class MyThread extends Thread {

    private final Object lock = new Object();

    private boolean pause = false;

    /**
     * 調(diào)用該方法實(shí)現(xiàn)線程的暫停
     */
    void pauseThread(){
        pause = true;
    }


    /*
    調(diào)用該方法實(shí)現(xiàn)恢復(fù)線程的運(yùn)行
     */
    void resumeThread(){
        pause =false;
        synchronized (lock){
            lock.notify();
        }
    }

    /**
     * 這個(gè)方法只能在run 方法中實(shí)現(xiàn)，不然會(huì)阻塞主線程，導(dǎo)致頁(yè)面無(wú)響應(yīng)
     */
    void onPause() {
        synchronized (lock) {
            try {
                lock.wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

    @Override
    public void run() {
        super.run();
        int index = 0;
        while(true){
            while (pause){
                onPause();
            }
            try {
                System.out.println(index);
                Thread.sleep(50);
                ++index;
            }catch (Exception e){
                e.printStackTrace();
                break;
            }
        }
    }
}

上面代碼中，有注釋?zhuān)鋵?shí)大家應(yīng)該都看得懂，那么主要是我們使用同步鎖synchronized對(duì)Objecy類(lèi)型的lock進(jìn)行同步，并在OnPause()方法中進(jìn)行wait()方法，線程等待，又在resumeThread（）方法中進(jìn)行了解鎖notify()，所以我們就能進(jìn)行線程的暫停和繼續(xù)的操作了

方法的調(diào)用

  MyThread my = new MyThread();
        Thread thread = new Thread(my);
        thread.start();

        try {
            sleep(1000);
            my.pauseThread();
            sleep(5000);
            my.resumeThread();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

出現(xiàn)的結(jié)果，會(huì)在前一秒內(nèi)瘋狂自增，之后在聽(tīng)五秒后，又開(kāi)始繼續(xù)自增；