spring线程池工具

spring线程池工具相关知识

• 线程池内部工作原理

  随着cpu核数越来越多，不可避免的利用多线程技术以充分利用其计算能力。所以，多线程技术是服务端开发人员必须掌握的技术。线程的创建和销毁，都涉及到系统调用，比较消耗系统资源，所以就引入了线程池技术，避免频繁的线程创建和销毁。在Java中有一个Executors工具类，可以为我们创建一个线程池，其本质就是new了一个ThreadPoolExecutor对象。线程池几乎也是面试必考问题。本节结合源代码，说说ThreadExecutor的工作原理一、线程池创建先看一下ThreadPoolExecutor参数最全的构造方法：corePoolSize：线程池的核心线程数，说白了就是，即便是线程池里没有任何任务，也会有corePoolSize个线程在候着等任务。maximumPoolSize：最大线程数，不管你提交多少任务，线程池里最多工作线程数就是maximumPoolSize。keepAliveTime：线程的存活时间。当线程池里的线程数大于corePoolSize时，如果等了keepAliveTime时长还没有任务
• 源码|从串行线程封闭到对象池、线程池

  今天讲一个牛逼而实用的概念，串行线程封闭。对象池是串行线程封闭的典型应用场景；线程池糅合了对象池技术，但核心实现不依赖于对象池，很容易产生误会。本文从串行线程封闭和对象池入手，最后通过源码分析线程池的核心原理，厘清对象池与线程池之间的误会。JDK版本：oracle java 1.8.0_102线程封闭与串行线程封闭线程封闭线程封闭是一种常见的线程安全设计策略：仅在固定的一个线程内访问对象，不对其他线程共享。使用线程封闭技术，对象O始终只对一个线程T1可见，“单线程”中自然不存在线程安全的问题。ThreadLocal是常用的线程安全工具，见源码|ThreadLocal的实现原理。线程封闭在Servlet及高层的web框架Spring等中应用不少。串行线程封闭线程封闭虽然好用，却限制了对象的共享。串行线程封闭改进了这一点：对象O只能由单个线程T1拥有，但可以通过安全的发布对象O来转移O的所有权；在转移所有权后，也只有另一个线程T2能获得这个O的所有权，并且发布O的T1不会再访问O。所谓“所有权”，指修改对象的权
• 0113 spring定时任务和异步线程池

  0113 spring的异步方法和定时任务 背景 spring的内容比较多，常规的知识必须进行系统化的学习，但是一些边缘的技术点，在实际工作中也是非常适用的；下面一一介绍和实践一次。 异步线程池 场景：下发任务跟执行任务分开。 比如我需要做一个数据统计。 场景 常规做法 改进做法 计算每天的统计数据，比如日新增，日活跃，日留存等 实时计算，计算和获取结果在同一个线程里完成 分两个部分：1.触发计算；2.异步完成计算； spring中如何实现异步计算 系统中配置异步线程池； 在系统入
• juc-12-线程池2-线程池的使用

  这是线程池第二篇文章，上一篇文章写了如何创建线程池，这篇文章用代码来演示通过 ThreadPoolExecutor 和 Executors的静态工厂方法创建线程池，以及这些线程池的基本使用，然后重点讲解 ThreadPoolExecutor 的实现接口 ExecutorService 中的常用API，如何通过这些API来管理线程池。 1、ThreadPoolExecutor 创建线程池 从上篇文章《juc-12-线程池2-线程池的使用》中，我们学习到 ThreadPoolExecutor 几个重载的构造函数都会调用下面这个构造函数： ThreadPoolExecutor(int corePool

spring线程池工具相关课程

• 玩转Java并发工具，精通JUC，成为并发多面手 本课程深度解密JUC库，对Java并发常见的工具类进行从使用到原理的详解，包括CAS+AQS+ThreadLocal+ConcurrentHashMap+线程池+各种锁+并发综合实战项目等。在掌握工具的同时，建立起整个并发工具类的知识体系。

  讲师：悟空 中级 1547人正在学习

• Spring源码轻松学 一课覆盖Spring核心知识点 课程在自研框架和Spring框架的穿插讲解中让大家逐渐熟悉Spring框架的脉络。通过从0搭建一个较为完备的Web框架来提升框架设计能力，辅以通俗易懂的Spring核心模块源码的讲解，带你了解Spring框架的设计思路。

  讲师：翔仔 中级 1357人正在学习

• Spring Cloud Alibaba微服务从入门到进阶 Spring Cloud Alibaba是阿里微服务的解决方案与精华沉淀。学习本课程，能熟练掌握Spring Cloud Alibaba的使用和原理，并带领大家从0开始编写一个学习笔记微信小程序，在实践中深入理解微服务思想。

  讲师：大目 中级 2702人正在学习

spring线程池工具相关教程

• 2.3 线程池 假设您要处理数百个项目，为每个项目启动一个线程将破坏您的系统资源。它看起来像这样：pages_to_crawl = %w( index about contact ... )pages_to_crawl.each do |page| Thread.new { puts page }end如果这样做，您将与服务器启动数百个连接，因此这可能不是一个好主意。一种解决方案是使用线程池。线程池使您可以在任何给定时间控制活动线程的数量。您可以建立自己的池，但是我不建议你这样去做，Ruby有一个Gem可以为您完成这个操作。实例：require 'celluloid'class Worker include Celluloid def process_page(url) puts url endendpages_to_crawl = %w( index about contact products ... )worker_pool = Worker.pool(size: 5)# If you need to collect the return values check out 'futures'pages_to_crawl.each do |page| worker_pool.process_page(page)end这次只有5个线程在运行，完成后他们将选择下一个项目。
• 3.1 线程池隔离实现服务资源隔离 通过对处理项目中的工作线程的隔离，来避免工作线程处理接口时所产生的阻塞行为，从而保证工作线程可以顺利地调用接口来满足业务需要。而隔离工作线程的方式，就是为每个接口分配一个线程池，并在线程池中维护一定数量的线程，这样，当上述的接口 2 发生服务资源等待时，由于每个接口都分配了不同的线程池，所以不会影响到后续的 3 4 5 接口，如下图所示：线程池隔离实现原理可以看到，由于为每个服务接口均分配了不同的线程池，所以在接口 2 出现服务等待时，并不会影响后续接口的调用，从而保证了业务的顺利进行。我们继续以 hello 方法为例，来看如何实现线程池隔离。@RequestMapping(value = "hello", method = RequestMethod.GET)@HystrixCommand(threadPoolKey = "HelloHystrix", threadPoolProperties = { @HystrixProperty(name = "coresize", value = "2"), @HystrixProperty(name = "allowMaximumSizeToDivergeFromCoreSize", value = "true"), @HystrixProperty(name = "maximumSize", value = "2"), @HystrixProperty(name = "maxQueueSize", value = "2")})@ResponseBodypublic String hello() throws InterruptedException { return "helloWorld";}代码解释：第 2 行，我们通过配置 HystrixCommand 注解的 threadPoolKey 属性来为本接口分配一个名称为 HelloHystrix 的线程池。第 3 行，我们通过配置 threadPoolProperties 中的参数属性，来维护 HelloHystrix 线程池中的核心线程数量、最大线程数量。通过添加上述注解并配置其中的属性，我们就可以通过线程池隔离的方式来实现服务资源隔离。Tips: 线程池中的线程数量，一定要根据该接口所实现的业务需求来设置，设置过多，则会浪费资源空间，设置过少，则不能支撑业务需要，所以配置线程数量一定要谨慎。
• 3. 线程池模型 线程池模型的结构如下：从图中可以看出，线程池模型的程序结构如下：创建一个监听线程，通常会采用 Java 主线程作为监听线程。创建一个 java.net.ServerSocket 实例，调用它的 accept 方法等待客户端的连接。服务器预先创建一组线程，叫做线程池。线程池中的线程，在服务运行过程中，一直运行，不会退出。当有新的客户端和服务器建立连接，accept 方法会返回 java.net.Socket 对象，表示新的连接。服务器一般会创建一个处理 java.net.Socket 逻辑的任务，并且将此任务投递给线程池去处理。然后，监听线程返回，继续调用 accept 方法，等待新的客户端连接。线程池调度空闲的线程去处理任务。在新新任务中调用 java.net.Socket 的 recv 和 send 方法和客户端进行数据收发。当数据收发完成后，调用 java.net.Socket 的 close 方法关闭连接，任务完成。线程重新回归线程池，等待调度。下来，我们同样通过示例代码演示一下线程池模型的编写方法。程序功能和每线程模型完全一致，所以我们只编写服务端程序，客户端程序采用每线程模型的客户端。示例代码如下：import java.io.*;import java.net.ServerSocket;import java.net.Socket;import java.util.concurrent.Callable;import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;public class TCPServerThreadPool{ // 服务监听端口号 private static final int PORT =56002; // 开启线程数 private static final int THREAD_NUMS = 20; private static ExecutorService pool = null; // 创建一个 socket Task 类，处理数据收发 private static class SockTask implements Callable<Void> { private Socket sock = null; public SockTask(Socket sock){ this.sock = sock; } @Override public Void call() throws Exception { try { while (true){ // 读取客户端数据 DataInputStream in = new DataInputStream( new BufferedInputStream(sock.getInputStream())); int msgLen = in.readInt(); byte[] inMessage = new byte[msgLen]; in.read(inMessage); System.out.println("Recv from client:" + new String(inMessage) + "length:" + msgLen); // 向客户端发送数据 String rsp = "Hello Client!\n"; DataOutputStream out = new DataOutputStream( new BufferedOutputStream(sock.getOutputStream())); out.writeInt(rsp.getBytes().length); out.write(rsp.getBytes()); out.flush(); System.out.println("Send to client:" + rsp + " length:" + rsp.getBytes().length); } } catch (IOException e) { e.printStackTrace(); } finally { if (sock != null){ try { sock.close(); } catch (IOException e) { e.printStackTrace(); } } } return null; } } public static void main(String[] args) { ServerSocket ss = null; try { pool = Executors.newFixedThreadPool(THREAD_NUMS); // 创建一个服务器 Socket ss = new ServerSocket(PORT); while (true){ // 监听新的连接请求 Socket conn = ss.accept(); System.out.println("Accept a new connection:" + conn.getRemoteSocketAddress().toString()); pool.submit(new SockTask(conn)); } } catch (IOException e) { e.printStackTrace(); } finally { if (ss != null){ try { ss.close(); } catch (IOException e) { e.printStackTrace(); } } } }}
• 3.3 线程池配置模块详解 参数名称：coreSize参数说明：该属性用来设置核心线程池的大小，默认为 10 。参数名称：maximumSize参数说明：该属性是用来设置线程池的最大线程数量，默认为 10 ，在 1.5.9 版本之前，线程池的核心线程数量总是与线程池的最大线程数量保持一致。参数名称：allowMaximumSizeToDivergeFromCoreSize参数说明：该属性是用来设置，是否启用 maximumSize ，即设置线程池的 coreSize 和 maximumSize 的值不一致，当被设置为 true 时，该属性生效，即线程池的最大线程数量大于或等于线程池的核心线程数量。该属性的默认值为 false 。参数名称：keepAliveTimeMinutes参数说明：该参数是用来设置线程的存活时间，即在线程池的核心线程数量小于线程池的最大线程数量时，一个线程的可运行时长。该属性的默认值为 1 分钟。
• 3. 工具对比 在介绍每一类工具类时，没有过多地做彼此之间的对比，为了大家有一个更深刻的认识，下面总结这些工具类之间的应用差异。请看下面表格。工具类基本概念典型应用场景 AtomicInteger 原子整型工具类，封装了基本类型整型变量的细粒度原子操作应用在多线程操作同一个整型变量时 AtomicReference 原子引用工具类，封装了引用类型变量的细粒度原子操作应用在多线程操作同一个引用变量时 DoubleAdder 浮点型加法器， 封装了基本类型浮点型变量的粗粒度原子操作应用在多线程统计汇总某一个数值时 LongAccumulator 长整型计算器，封装了基本类型长整型变量的自定义运算规则的原子操作应用在多线程操作同一个长整型变量且需自定义计算规则时
• 3. 工具对比 在介绍每一类工具类时，没有过多地做彼此之间的对比，为了大家有一个更深刻的认识，下面总结这些工具类之间的应用差异。请看下面表格。工具类基本概念典型应用场景 Semaphore 计数信号量，封装了对某个资源的量化控制操作生产消费关系中的逻辑控制 CountDownLatch 同步计数器，封装了多个子线程和一个控制线程之间的同步逻辑分头处理任务，最后做总结性处理 CyclicBarrier 循环栅栏， 封装了多个线程在某个时刻达成同步逻辑类似 CountDownLatchPhaser 移相器，封装了具有多阶段且每阶段并发处理的控制逻辑如处理某个具有多阶段任务的计划 Exchanger 交换者，封装了一对线程之间的同步交换逻辑如两个任务在处理过程中，需互相检测信息的场合

spring线程池工具相关搜索

s line safari浏览器 samba SAMP samplerate sandbox sanitize saper sas sass save smarty模板 smil smtp snapshot snd snmptrap soap soapclient soap协议

查看更多慕课网实用课程