首页 > 编程语言 >Java中使用Hutool的ExecutorBuilder实现自定义线程池

Java中使用Hutool的ExecutorBuilder实现自定义线程池

时间:2022-09-22 14:15:44浏览次数:87  
标签:Java 自定义 队列 Hutool static session 线程 ExecutorBuilder import

场景

Java中ExecutorService线程池的使用(Runnable和Callable多线程实现):

https://blog.csdn.net/BADAO_LIUMANG_QIZHI/article/details/126242904

SpringBoot+Lombok+Builder实现任意个数属性的对象构造:

https://blog.csdn.net/BADAO_LIUMANG_QIZHI/article/details/126384244

上面讲了自定义线程池的使用以及Builder构造者模式的一个简单应用。

是否可以将两者结合使用,Hutool中已经实现了这一点。

文档说明

https://www.hutool.cn/docs/#/core/%E7%BA%BF%E7%A8%8B%E5%92%8C%E5%B9%B6%E5%8F%91/%E8%87%AA%E5%AE%9A%E4%B9%89%E7%BA%BF%E7%A8%8B%E6%B1%A0-ExecutorBuilder

自定义线程池ExecutorBuilder

在JDK中,提供了Executors用于创建自定义的线程池对象ExecutorService,但是考虑到线程池中存在众多概念,这些概念通过不同的搭配实现灵活的线程管理策略,单独使用Executors无法满足需求,构建了ExecutorBuilder。

概念

corePoolSize 初始池大小
maxPoolSize 最大池大小(允许同时执行的最大线程数)
workQueue 队列,用于存在未执行的线程
handler 当线程阻塞(block)时的异常处理器,所谓线程阻塞即线程池和等待队列已满,无法处理线程时采取的策略

线程池对待线程的策略

1、如果池中任务数<corePoolSize,放入立即执行。

2、如果池中任务数>corePoolSize,放入队列等待。

3、队列满,新建线程立即执行。

4、执行中的线程>maxPoolSize,触发handler(RejectedExecutionHandler)异常。

workQuene线程池策略

SynchronousQueue它将任务直接提交给线程而不保持他们。当运行线程小于maxPoolSize时会创建新线程,否则触发异常策略。

LinkedBlockingQueue默认无界队列,当运行线程大于corePoolSize时始终放入此队列,此时maxPoolSize无效。当构造LinkedBlockingQuene

对象时传入参数,变成有界队列,队列满时,运行线程小于maxPoolSize时会创建新线程,否则触发异常策略。

ArrayBlockingQuene有界队列,相对无界队列有利于控制队列大小,队列满时,运行线程小于maxPoolSize时会创建新线程,否则触发异常策略。

注:

博客:
https://blog.csdn.net/badao_liumang_qizhi
关注公众号
霸道的程序猿
获取编程相关电子书、教程推送与免费下载。

实现

1、使用示例-默认线程池

ExecutorService executor = ExecutorBuilder builder = ExecutorBuilder.create()..build();

初始线程数为corePoolSize指定的大小
没有最大线程数限制
默认使用LinkedBlockingQueue,默认队列大小为1024(最大等待数1024)
当运行线程大于corePoolSize放入队列,队列满后抛出异常

2、使用示例-单线程线程池

ExecutorService executor = ExecutorBuilder.create()//
    .setCorePoolSize(1)//
    .setMaxPoolSize(1)//
    .setKeepAliveTime(0)//
    .build();

初始线程数为 1
最大线程数为 1
默认使用LinkedBlockingQueue,默认队列大小为1024
同时只允许一个线程工作,剩余放入队列等待,等待数超过1024报错

3、使用示例-更多选项

ExecutorService executor = ExecutorBuilder.create()
    .setCorePoolSize(5)
    .setMaxPoolSize(10)
    .setWorkQueue(new LinkedBlockingQueue<>(100))
    .build();

初始5个线程
最大10个线程
有界等待队列,最大等待数是100

4、使用示例-特殊策略

ExecutorService executor = ExecutorBuilder.create()
    .setCorePoolSize(5)
    .setMaxPoolSize(10)
    .useSynchronousQueue()
    .build();

初始5个线程
最大10个线程
它将任务直接提交给线程而不保持它们。当运行线程小于maxPoolSize时会创建新线程,否则触发异常策略

5、业务中使用示例

引入项目依赖

        <dependency>
            <groupId>cn.hutool</groupId>
            <artifactId>hutool-all</artifactId>
            <version>5.8.3</version>
        </dependency>

使用示例

    private static ExecutorService pool = ExecutorBuilder.create()
            .setCorePoolSize(20)//初始20个线程
            .setMaxPoolSize(40)//最大40个线程
            .setWorkQueue(new LinkedBlockingQueue<>(60))//有界等待队列,最大等待数是60
            .setThreadFactory(ThreadFactoryBuilder.create().setNamePrefix("IM-Pool-").build())//设置线程前缀
            .build();

完整使用示例

package com.chrisf.imextend;

import cn.hutool.core.thread.ExecutorBuilder;
import cn.hutool.core.thread.ThreadFactoryBuilder;
import com.chrisf.sdk.protocal.Protocal;
import com.chrisf.sdk.utils.LocalSendHelper;
import io.netty.channel.Channel;
import java.util.Collection;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.LinkedBlockingQueue;

/**
 * im 客户端用户集
 *
 * @author yansh
 */
public class ImUsers {

    private static ExecutorService pool = ExecutorBuilder.create()
            .setCorePoolSize(20)//初始20个线程
            .setMaxPoolSize(40)//最大40个线程
            .setWorkQueue(new LinkedBlockingQueue<>(60))//有界等待队列,最大等待数是60
            .setThreadFactory(ThreadFactoryBuilder.create().setNamePrefix("IM-Pool-").build())//设置线程前缀
            .build();

    /**
     * 用户集
     */
    private static Map<String, Channel> USERS = new ConcurrentHashMap<String, Channel>();

    /**
     * 存储用户
     *
     * @param key     唯一键
     * @param session 用户信息
     */
    public static void put(String key, Channel session) {
        USERS.put(key, session);
    }

    /**
     * 移除用户
     *
     * @param session 用户信息
     * @return 移除结果
     */
    public static boolean remove(Channel session) {
        String key = null;
        boolean flag = USERS.containsValue(session);
        if (flag) {
            Set<Map.Entry<String, Channel>> entries = USERS.entrySet();
            for (Map.Entry<String, Channel> entry : entries) {
                Channel value = entry.getValue();
                if (value.equals(session)) {
                    key = entry.getKey();
                    break;
                }
            }
        } else {
            return true;
        }
        return remove(key);
    }

    /**
     * 移出用户
     *
     * @param key 键
     */
    public static boolean remove(String key) {
        Channel remove = USERS.remove(key);
        if (remove != null) {
            boolean containsValue = USERS.containsValue(remove);
            return containsValue;
        } else {
            return true;
        }
    }

    /**
     * 获取在线用户列表
     *
     * @return 返回用户集合
     */
    public static Map<String, Channel> getUsers() {
        return USERS;
    }

    /**
     * 群发消息文本消息
     *
     * @param protocal 消息内容
     */
    public static void sendMessageToUsersByText(Protocal protocal) {
        Collection<Channel> values = USERS.values();
        for (Channel value : values) {
            pool.submit(() -> sendMessageToUserByText(value, protocal));
        }
    }

    /**
     * 发送消息
     *
     * @param session
     * @param protocal
     */
    public static void sendMessageToUserByText(Channel session, Protocal protocal) {
        if (session != null) {
            synchronized (session) {
                try {
                    LocalSendHelper.sendData(session,protocal,null);
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        } else {

        }
    }
}

 

标签:Java,自定义,队列,Hutool,static,session,线程,ExecutorBuilder,import
From: https://www.cnblogs.com/badaoliumangqizhi/p/16719023.html

相关文章

  • java学习笔记25
    java数组数组的定义数组是相同类型数据的有序集合。数组描述的是相同类型的若干个数据按照一定的先后次序排列组合而成。其中,每一个数据称作一个数组元素,每个数组元素......
  • java学习笔记26
    java数组数组的使用普通的for循环publicclassDemo03{  publicstaticvoidmain(String[]args){    int[]arrays={1,2,3,4,5};    //打印......
  • java - @Async 具体使用
    1.开启  @Async异步能力添加注解 @EnableAsync,可以放在启动类上,也可以在任意配置类上,因为我是需要配置自定义线程池,因此放在配置类上importorg.springframework.c......
  • JAVA常用工具类
    java开发常用工具类java正则表达式的匹配包括:邮箱,手机,姓名,昵称,身份证号,银行卡号等;生成6位随机数;对url中字符串进行编码和解码;获取客户端ip地址;获取系统当前时间;生......
  • java中String的常用方法
    1、length()字符串的长度例:charchars[]={'a','b'.'c'};Strings=newString(chars);intlen=s.length();2、charAt()截取一个字符例:charch......
  • JAVA中容器设计的进化史:从白盒到黑盒,再到跻身为设计模式之一的迭代器
    大家好,又见面了。在我们的项目编码中,不可避免的会用到一些容器类,我们可以直接使用List、Map、Set、Array等类型。当然,为了体现业务层面的含义,我们也会根据实际需要自行封......
  • Java SE 19 新增特性
    JavaSE19新增特性作者:Grey原文地址:博客园:JavaSE19新增特性CSDN:JavaSE19新增特性源码源仓库:Github:java_new_features镜像仓库:GitCode:java_new_features......
  • JavaScript 函数定义
    JavaScript使用关键字 function 定义函数。函数可以通过声明定义,也可以是一个表达式。函数声明:函数声明后不会立即执行,会在我们需要的时候调用到。functionmyFunct......
  • 学习Java Day1
    Markdown学习Day1笔记划线层级标题+空格井号的多少表示层级的大小字体粗体为文字前后输入各两个“星号”——**斜体为文字前后输入各一个“星号”——*斜体......
  • java批量采集豌豆荚网站Android应用图标和包名
    Android主题开发者做的主题,如果想代替第三方应用图标,就必须要知道应用的包名。其实想知道应用的包名很简单,直接在浏览器打开GooglePlay或豌豆荚,打开某应用的页面,看网址你......