设计模式之多线程分工模式--- Thread-Per-Message

发布时间:2024年01月15日

系列文章目录

提示:这里可以添加系列文章的所有文章的目录,目录需要自己手动添加
例如:第一章 Python 机器学习入门之pandas的使用


提示:写完文章后,目录可以自动生成,如何生成可参考右边的帮助文档


前言

Thread-Per-Message 模式需要注意线程的创建,销毁以及是否会导致OOM。


简介

  • Thread-Per-Message 模式—简单实用的分工方法
  • Thread-Per-Message 模式就是为每个任务分配一个独立的线程,这是一种最简单的分工方法。
  • Thread-Per-Message 模式作为一种最简单的分工方案,Java 中使用会存在性能缺陷。在Java中的线程是一个重量级的对象,创建成本很高,第一点创建线程比较耗时,第二点线程占用的内存也比大。所以为每个请求创建一个新的线程并不适合高并发场景。为了解决这个缺点,Java并发包里提供了线程池等工具类。
  • 在其他编程语言里,例如 Go 语言,基于轻量级线程实现 Thread-Per-Message 模式就完全没有问题。
  • 对于一些并发度没那么高的异步场景,例如定时任务,采用 Thread-Per-Message 模式是完全没有问题的。

应用场景

在Java中的线程是一个重量级的对象,创建成本很高,第一点创建线程比较耗时,第二点线程占用的内存也比大。所以为每个请求创建一个新的线程并不适合高并发场景

/**
 * @author yang
 * @version 1.0.0
 */
public class ThreadPerMessageExample {
    public static void main(String[] args) {
        TaskHandler taskHandler = new TaskHandler();
        for (int i = 0; i < 5; i++) {
            String task = "任务" + i;
            taskHandler.handleTask(task);
        }
    }
    static class TaskHandler {
        public void handleTask(String task) {
            Thread thread = new Thread(() -> {
                System.out.println("处理" + task + " 在线程" + Thread.currentThread().getName());
            });
            thread.start();
        }
    }
}

Thread-Per-Message 模式的一个最经典的应用场景是网络编程里服务端的实现,服务端为每个客户端请求创建一个独立的线程,当线程处理完请求后,自动销毁,这是一种最简单的并发处理网络请求的方法。

文章来源:https://blog.csdn.net/weixin_44859605/article/details/135595398
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。