开发者

Java实现线程的暂停和恢复的示例详解

开发者 https://www.devze.com 2023-11-24 10:19 出处:网络 作者: 桃花键神
目录问题思路问题答案其他方法最后问题思路 在Java中,线程的暂停和恢复可以通过Thread类的interrupt方法实现。需要注意的是,interrupt方法并不会立即停止线程,而是会设置一个中断标记,你编程客栈需要在你的线程中
目录
  • 问题思路
  • 问题答案
  • 其他方法
  • 最后

问题思路

在Java中,线程的暂停和恢复可以通过Thread类的interrupt方法实现。需要注意的是,interrupt方法并不会立即停止线程,而是会设置一个中断标记,你编程客栈需要在你的线程中适当地响应这个中断。

以下是一个简单的示例:

问题答案

public class MyThread extends Thread {  
    private volatile boolean isInterrupted = false;  
  
    @Override  
    public void run() {  
        while (!isInterrupted) {  
            // 线程正在执行的任务...  
        }  
    }  
  
    public void interruptThread() {  
        isInterrupted = true;  
    }  
  
    public void resetInterrupt() {  
        isInterrupted = false;  
    }  
}

在这个例子中,我们创建了一个继承自Thread的类,并添加了一个isInterrupted标志来跟踪线程是否被中断。在run方法中,我们检查这个标志,如果它被设置为true,那么我们就退出循环,线程就会结束。

你可以通过调用interruptThread方法来中断线程,并通过调用resetInterrupt方法来重置中断状态。需要注意的是,当线程被中断时,它会抛出InterruptedException,你需要在你的代码中处理这个异常。

其他方法

自定义线程类(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;

    /**
     * 调用该方法实现线程的暂停
     */
    void pauseThread(){
        pause = true;
    }


    /*
    调用该方法实现恢复线程的运行
     */
    void resumeThread(){
        pause =false;
        synchronized (lock){
            lock.notify();
        }
    }

    /**
     * 这个方法只能在run 方法中实现,不然会阻塞主线程,导致页面无响应
     */
    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;
            }
        }
    }
}

上面代码中,有注释,其实大家应该都看得懂,那么主要是我们使用同步锁synchronized对Objecy类型的lock进行同步,并在OnPause()方法中进行wait()方法,线程等待,又在resumeThread()方法中进行了解锁notify(),所以我们就能进行线程的暂停和继续的操作了

方法的调用

  MyTjshread my = new MyThread();
        Thread thread = new Thread(my);
        thre编程客栈ad.start();

        try {
            sleep(1000);
            my.pauseThread();
            sleep(5000);
            my.resumeThread();
        } catch (InterruptedException e) {
            e.prin编程客栈tStackTrace();
        }

出现的结果,会在前一秒内疯狂自增,之后在www.devze.com听五秒后,又开始继续自增;

最后

以上就是Java实现线程的暂停和恢复的示例详解的详细内容,更多关于Java线程暂停和恢复的资料请关注编程客栈(www.devze.com)其它相关文章!

0

精彩评论

暂无评论...
验证码 换一张
取 消

关注公众号