首页 > 其他分享 >线程池的介绍与实现(多线程代码案例)

线程池的介绍与实现(多线程代码案例)

时间:2024-03-28 11:00:19浏览次数:19  
标签:Thread int 案例 任务 线程 多线程 final ThreadPoolExecutor

目录

概念:

ThreadPoolExecutor

int corePoolSize

int maximumPoolsize

long keepAliveTime

TimeUnit unit

BlockingQueue wokrQueue

Thread threadFactory

RejectedExecutionHandler handler

1.ThreadPoolExecutor.Abortpolicy

2.ThreadPoolExecutor.CallerRunsPolicy

3.ThreadPoolExecutor.DiscardOldestPolicy

4.ThreadPoolExecutor.DiscardPolicy

ExecutorService

线程池的简单实现


概念:

了解线程池,首先我们要了解池的概念

池:把要用的对象准备好,用完的对象不要释放,而是留着下次使用.例如常量池,数据库连接池,线程池进程池,内存池.

我们计算机引入线程是线程的创建和销毁开销少,可以减少计算机的负担,但是大量线程进行创建和销毁还是会使电脑的处理效率下降

所以我们引出了线程池的概念

所谓线程池,就是我们提前创建好多个线程,使用完成之后不销毁已备下次使用

ThreadPoolExecutor

标准库的线程池 ThreadPoolExecutor 其构造方法参数十分重要.

int corePoolSize

核心线程数量,最少有多少个线程. (相当于一个公司的正式员工)

int maximumPoolsize

最大线程数量,最多有多少个线程.(多出来的这些相当于外包员工,召之即来,挥之即去)

long keepAliveTime

最长存活时间.(当外包员工没有任务时,处于空闲状态,等待存活时间后就会将外包员工开除)

TimeUnit unit

时间单位

BlockingQueue<Runnable> wokrQueue

和我们上一期的计时器一样,我们的线程池也是可以执行多个任务的(理所应当的,线程池肯定执行的任务也多),这个优先级队列就是用来储存任务的.

Thread threadFactory

线程工厂

可以设定线程名,守护线程.

RejectedExecutionHandler handler

拒绝策略.在线程池中有阻塞队列,那么容纳的线程就是有极限的.如果线程池已经满了,此时就需要使用拒绝策略.

而我们的拒绝策略有四种:

1.ThreadPoolExecutor.Abortpolicy

继续添加任务直接抛出异常

例如:你现在正在写作业,已经将队列占满了,作业很多,妈妈让你扫地,你作业也不写,地也不扫了,直接什么都不干了.

2.ThreadPoolExecutor.CallerRunsPolicy

新的添加任务由添加任务的线程完成.   

妈妈让你扫地,你说你很忙,然后让妈妈去扫地

3.ThreadPoolExecutor.DiscardOldestPolicy

丢弃最早的任务.     不写作业了,只去扫地

4.ThreadPoolExecutor.DiscardPolicy

丢弃最新的任务.     不扫地,只写作业

ExecutorService

Executor相较于ThreadPoolExecutor,都是用来设定线程池,但是很明显,ExecutorService线程池的参数更少,我们在使用中如果只是简单的使用线程池,就可以用这个简化版的.

newFixedThreadPool方法实例化的线程池表示有固定线程数量,括号中就是其线程数量.

而其sumbit很明显是用来提交任务的,但是执行哪个任务的具体线程是随机的.

线程池的简单实现

根据上述线程池的特点,我们可以总结出

1.线程池有多个线程的,所以我们需要一个数据结构来储存线程.

2.任务也是多个,而且我们尽量保证先提交的任务优先进行,此时就需要队列容纳任务

3.构造方法创建n个线程我们需要用循环来创建

4.submit方法接收任务

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingDeque;
import java.util.concurrent.BlockingQueue;

class MyExecutorService{
    //数组容纳线程
    List<Thread> list = new ArrayList<>();
    //队列容纳任务
    BlockingQueue<Runnable> queue = new ArrayBlockingQueue<>(10000);
    //构造方法
    public MyExecutorService(int n ){
        for (int i = 0; i < n; i++) {
            //构建线程
            Thread t = new Thread(() ->{
                while(true){
                    try {
                        //此处的take是带有阻塞功能的,如果队列为空,take就会进入阻塞
                        Runnable runnable = queue.take();
                        runnable.run();
                    } catch (InterruptedException e) {
                        throw new RuntimeException(e);
                    }
                }
            });
            //启动线程
            t.start();
            //将线程放入线程数组
            list.add(t);
        }
    }
    public void Submit(Runnable runnable){
        queue.offer(runnable);
    }
}
public class ThreadPool {
    public static void main(String[] args) {
        MyExecutorService myExecutorService = new MyExecutorService(4);
        for (int i = 0; i < 1000; i++) {
            int n = i;
            //此时每次循环进来都会新建一个n,n不发生改变为事实final变量
            myExecutorService.Submit(() ->{
                //此处的i涉及到变量捕获,因为i在匿名内部类当中,所以i必须是final或者事实final,事实final就是之后不会改变
                //我们可以在循环外部新设置一个变量n,此时n就是事实final,再将i传入final

                System.out.println("执行任务"+n+" "+"执行线程"+Thread.currentThread().getName());
            });
        }
    }
}

这个代码总体来说比较简单,没有涉及到大量的线程安全问题.

标签:Thread,int,案例,任务,线程,多线程,final,ThreadPoolExecutor
From: https://blog.csdn.net/a13931329858/article/details/136973174

相关文章

  • 实测52.4MB/s!全国产ARM+FPGA的CSI通信案例分享!
    CSI总线介绍与优势CSI(CMOSsensorparallelinterfaces)总线是一种用于连接图像传感器和处理器的并行通信接口,应用于工业自动化、能源电力、智慧医疗等领域,CSI总线接口示意图如下所示(以全志科技T3处理器的CSI0为例)。  图1高带宽:CSI总线支持高速数据传输,可以满足多通道高速......
  • 探索华为云CCE敏捷版金融级高可用方案实践案例
    本文分享自华为云社区《华为云CCE敏捷版金融级高可用方案实践》,作者:云容器大未来。一、背景1.1.CCE敏捷版介绍云原生技术有利于各组织在公有云、私有云和混合云等新型动态环境中,构建和运行可弹性扩展的应用。云原生的代表技术包括容器、服务网格、微服务、不可变基础设施和......
  • 【Flutter 面试题】 Dart 是不是单线程模型?是如何运行的?
    【Flutter面试题】Dart是不是单线程模型?是如何运行的?文章目录写在前面口述回答补充说明示例:异步编程示例:使用Isolates处理计算密集型任务总结写在前面......
  • SAP BTP云上一个JVM与DB Connection纠缠的案例
    前言最近在CF(CloudFoundry)云平台上遇到一个比较经典的案例。因为牵扯到JVM(app进程)与数据库连接两大块,稍有不慎,很容易引起不快。在云环境下,有时候相互扯皮的事蛮多。如果是DB的问题,就会找DB相关部门。关键是如何自证。涉及到职场生存法则,大家都不愿意去背锅,谁背锅,意......
  • dump文件分析OOM及线程堆栈
    OutOfMemoryError(OOM)如果项目报错:OutOfMemoryError:Javaheapspace,说明堆内存空间(HeapSpace)中没有足够的空间来分配对象了。一旦发生OOM,系统有可能不可用,或者频繁重启。属于非常严重的问题。OOM的解决方法一:比较简单粗暴的一种做法,是增大堆内存空间。在项目启动时,......
  • Scala第十二章节(Source读取数据的功能、写入数据的功能以及学员成绩表案例)
    章节目标掌握Source读取数据的功能掌握写入数据的功能掌握学员成绩表案例1.读取数据在Scala语言的Source单例对象中中,提供了一些非常便捷的方法,从而使开发者可以快速的从指定数据源(文本文件,URL地址等)中获取数据,在使用Source单例对象之前,需要先导包,即......
  • 并发锁与线程池(一)
    1.什么是线程?线程是操作系统能够进行运算调度的最小单位,它被包含在进程之中,是进程中的实际运作单位。一条线程指的是进程中一个单一顺序的控制流,一个进程中可以并发多个线程,每条线程并行执行不同的任务。在多核或多CPU系统中,线程可以被调度到不同的核心上执行,从而实现真正......
  • Profinet转ModbusTCP:从站设备转换与集成案例
    本案例旨在探讨如何将ModbusTCP设备数据成功地接入到西门子PROFINET网络中。为了实现这一目标,我们将使用西门子S7-1200型PLC以及Profinet转ModbusTCP网关作为关键设备。为了模拟Modbus从站,我们将使用电脑安装modbuspoll软件。首先需要了解Profinet和ModbusTCP这两种协议的基本概......
  • ThreadPool-线程池使用及原理
    1.线程池使用方式示例代码://一池N线程Executors.newFixedThreadPool(int)//一个任务一个任务执行,一池一线程Executors.newSingleThreadExecutorO//线程池根据需求创建线程,可扩容,遇强则强Executors.newCachedThreadPool()//自定义线程池方式newThreadPoolExec......
  • 【性能测试】线程数、并发数和TPS的关系
    项目背景某通信产品在提测阶段,领导要求支持1w人同时在线,支持1000并发,去测吧理解需求“支持1w人同时在线,支持1000并发”“1w人同时在线”这个理解起来简单一些,对于即时通讯产品来说,就是1w个长链接,直接写脚本建立长链接就行。“支持1000并发”这里就产生歧义了:1、什么功......