专栏首页帅哥哥写代码线程中断与再运行控制示例

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

本文目的

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

代码示例

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:本文的中断官方术语叫挂起。

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • 多线程同步控制使用示例升级版

    图二.png 这个结果看起很漂亮,但是实际上这个不太符合业务场景。尤其是大众代码,正常情况下应该是并发运行。看上图代码发现:

    用户5166330
  • 多线程同步控制使用示例

    运行结果 大家可以看到虽然一开始打印了进入特殊线程,但是却并未输出结束特殊线程,而是最后才执行,说明

    用户5166330
  • 基于h5+ angularjs页面拖拽实现

    第四步:定义函数,修改图片数组顺序(angualr最好用的地方之一就是双向绑定。所以只需要操作图片数组的顺序就可以实现页面上交换图片位置)。

    用户5166330
  • Java并发编程之显式锁机制

         我们之前介绍过synchronized关键字实现程序的原子性操作,它的内部也是一种加锁和解锁机制,是一种声明式的编程方式,我们只需要对方法或者代码块进...

    Single
  • XStream进行xml和bean互转

    老梁
  • 详解.NET Core 依赖注入生命周期

    分别新建 Scoped、Singleton、Transient 三种模式的服务与接口,里面写一个GetIndex() 方法获取index ,用来区别服务的生命周...

    心莱科技雪雁
  • 轻量级线程池的实现

    写在前面 最近因为项目需要,自己写了个单生产者-多消费者的消息队列模型。多线程真的不是等闲之辈能玩儿的,我花了两个小时进行设计与编码,却花了两天的时间调试与运...

    大闲人柴毛毛
  • [Java] CountDownLatch 与 CyclicBarrier

    A synchronization aid that allows one or more threads to wait until a set of ope...

    wOw
  • 集群下session共享问题的解决方案.

    一枝花算不算浪漫
  • Java三大面向对象特性

    Java 是面向对象的高级编程语言,类和对象是 Java 程序的构成核心。围绕着 Java 类和 Java 对象,有三大基本特性:封装是 Java 类的编写规范...

    润森

扫码关注云+社区

领取腾讯云代金券