线程中断与再运行控制示例

本文目的

实现多线程的中断与再运行。

代码示例

1.使用单例模式创建一个类去实现管理线程组
2.利用线程的suspend方法与resume方法实现线程的中断与再运行。线程终止利用线程的stop方法。

代码示例

管理线程组的单例类

package com.example.testdemo.block.thread;

import java.util.HashMap;
import java.util.Map;

public class Singleton {

    public Map<String, Map<String, TestThread>> threds = new HashMap<String, Map<String, TestThread>>();

    public static Singleton single = new Singleton();

    private Singleton() {

    }

    public static Singleton getSingleton() {
        return single;
    }
}

我选择单例模式是为了实现数据共享，同时还可以起到节省内存资源。为了操作简单，直接采用饿汉式的方式。

模拟线程类

package com.example.testdemo.block.thread;

import java.util.HashMap;
import java.util.Map;

public class TestThread extends Thread {

    private int start;
    private int end;
    private String descName;
    private String taskkey;

    public TestThread(int start, int end, String descName, String taskkey) {
        this.start = start;
        this.end = end;
        this.descName = descName;
        this.taskkey = taskkey;
    }

    @Override
    public void run() {
        for (; start < end; start++) {
            for (int i = 0; i < 30000; i++) {
                for (int j = 0; j < 30000; j++) {
                    for (int j2 = 0; j2 < 80000; j2++) {

                    }
                }
            }
            System.out.println(start + ">-" + descName + ">-" + taskkey);
        }
        addNewTask();
    }

    public void addNewTask() {
        Singleton s = Singleton.getSingleton();
        synchronized (s) {
            s.threds.get(taskkey).remove(descName);
            TestThread testThread = new TestThread(200, 210, descName, taskkey);
            Map<String, TestThread> map = new HashMap<String, TestThread>();
            map.put(descName, testThread);
            s.threds.get(taskkey).putAll(map);
            testThread.start();
        }
    }

    @Override
    public String toString() {
        return "TestThread [start=" + start + ", end=" + end + ", descName=" + descName + ", taskkey=" + taskkey + "]";
    }

    public int getStart() {
        return start;
    }

    public void setStart(int start) {
        this.start = start;
    }

    public int getEnd() {
        return end;
    }

    public void setEnd(int end) {
        this.end = end;
    }

    public String getDescName() {
        return descName;
    }

    public void setDescName(String descName) {
        this.descName = descName;
    }

    public String getTaskkey() {
        return taskkey;
    }

    public void setTaskkey(String taskkey) {
        this.taskkey = taskkey;
    }

}

四个属性：start:开始位置，end:结束位置（用于控制循环记数），descName:描述名称，taskkey:任务键。
在任务最后，会再次新建一个线程，新建的线程标识和结束的线程一样。
上面的空的for循环，只是为了输出慢一点。不用sleep，是因为这个方法偶尔会抛出异常。不安逸。

接口代码

package com.example.testdemo.controller;

import java.time.LocalDateTime;
import java.util.HashMap;
import java.util.Map;

import org.springframework.http.HttpStatus;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseStatus;
import org.springframework.web.bind.annotation.RestController;

import com.example.testdemo.block.thread.Singleton;
import com.example.testdemo.block.thread.TestThread;

import lombok.extern.slf4j.Slf4j;

@RestController
@RequestMapping("test/thread")
@Slf4j
public class TestOne {

    @GetMapping("/start")
    @ResponseStatus(code = HttpStatus.OK)
    public void testStart() {
        Singleton s = Singleton.getSingleton();
        buildTask(s);
    }

    private void buildTask(Singleton s) {
        TestThread testThrod1 = new TestThread(1, 60, "key1", "task1");
        TestThread testThrod2 = new TestThread(-60, 0, "key2", "task1");
        Map<String, TestThread> map = new HashMap<String, TestThread>();
        map.put(testThrod1.getDescName(), testThrod1);
        map.put(testThrod2.getDescName(), testThrod2);
        testThrod1.start();
        testThrod2.start();
        s.threds.put("task1", map);
    }

    @SuppressWarnings("deprecation")
    @GetMapping("/end")
    @ResponseStatus(code = HttpStatus.OK)
    public void endStart() throws InterruptedException {
        Singleton s = Singleton.getSingleton();
        synchronized (s) {
            if (null != s.threds.get("task1")) {
                s.threds.get("task1").values().forEach(t -> {
                    LocalDateTime localDateTime = LocalDateTime.now();
                    log.info(localDateTime + "");
                    t.suspend();
                });
            }
        }
        Thread.sleep(4000);
        synchronized (s) {
            if (null != s.threds.get("task1")) {
                s.threds.get("task1").values().forEach(t -> {
                    LocalDateTime localDateTime = LocalDateTime.now();
                    log.info(localDateTime + "");
                    t.resume();
                });
            }
        }

    }

}

1.start接口就会启动线程。这儿是启动两个线程。
2.end就会中断线程，四秒之后中断的线程会再次运行。
3.启动通过任务键给线程归类，中断则是通过任务键中断对应的线程组。

缺陷

suspend,resume,stop这样的方法都被标注为过期方法，因为其不会保证释放资源，容易产生死锁，所以不建议使用。

结果演示

swagger接口示例页面.png
调用start接口后端输出.png
调用end接口后端输出(1).png
调用end接口输出(2).png

通过图片可以看到，调用end接口，停止了输出，暂停4秒之后继续输出。证明调用end接口确实将线程挂起了。

tips:本文的中断官方术语叫挂起。