spring4线程池

spring4线程池相关知识

• java线程池和关闭线程池中的线程

  如果线程经常喜欢去new的话是不对的，你需要一个池子管理。 newCachedThreadPool 这个一个带缓存的线程池，是个可以无限大的线程池，新建的线程放倒这个池子里，当线程停掉了的时候，下个个线程进来，可以复用这个线程。 newFixedThreadPool 是个有长度的线程池，与上一个不同的是，当线程超越某个长度的时候，新进来的线程就会排队。线程池的大小最好匹配系统资源。按照系统资源来设置大小最好。 newScheduledThreadPool 可以执行周期性任务的定长线程池 newSingleThreadExecutor 任务
• juc-12-线程池2-线程池的使用

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

  Android中的线程池的概念来源于Java中的Executor，Executor是一个接口，真真的线程池的实现为ThreadPoolExecutor。ThreadPoolExecutor提供了一系列参数来配置线程池。Android的线程池主要分为4类。一、线程池的优点：重用线程池中的线程。能有效控制线程池的最大并发数，避免大量的线程之间因相互抢占资源而导致阻塞的现象。能够对线程进行简单的管理，并提供定时执行以指定间隔循环执行等功能。二、Android主要的四类线程池1.FixThreadPool它是一种线程数量固定的线程池，当线程处于空闲状态时，它们并不会被回收，除非线程池被关闭了。 ExecutorService fixedThreadPool = Executors.newFixedThreadPool(5);2.CachedThreadPool它是一种线程数量不定的线程池，它只有非核心线程，并且其最大线程数为Integer.MAX_VALUE。ExecutorService cachedThread
• 在Spring4中使用通用Mapper

  1.在Spring4中使用通用Mapper Spring4增加了对泛型注入的支持，这个特性对通用Mapper来说，非常的有用，可以说有了这个特性，可以直接在Service中写Mapper<UserInfo> mapper，可以通过BaseService<T>来实现通用的Service。 这篇文档主要讲解通用Mapper在Spring4中的最佳用法。 2.一、在Spring4中配置通用Mapper 和Spring3中的配置一样，配置方法请看这里有关Spring配置的信息。 如果有人不明白完整的配置什么样，可以看下面的例子： Mybatis-Spring4项目 applicationContext.xml 3.

spring4线程池相关课程

• 学透协程/进程/线程 程序员必知必会技能 作为市面上凤毛麟角的协程专题课，课程将从基础讲起，与应用原理联动，结合丰富的课程案例，使用Python语言进行落地实践。无论你是Java、Go还是PHP开发，都可以通过本门课程掌握协程原理。是一门非常适合新手学习高性能开发的课程。

  讲师：咚咚呛 中级 222人正在学习

• 告别996 双角度优化编程效率 实现Java高效编程 本课程致力于从“技术”和“工具”两大维度提高Java编程效率，主要包含：链式编程、流式编程、资源关闭、Google开源高效神器Guava、为自己锻造高效IDE神器等，极大化提升工作效率，契合企业刚需。

  讲师：张小喜 初级 1342人正在学习

• Dubbo 3 深度剖析 - 透过源码认识你 Apache Dubbo 3 从性能和云原生的角度提出了诸多特性，大大提升了开发效率。作为目前市面上稀缺的 “深度剖析” 精品课程，资深架构师将带领大家，探究 Dubbo 3 的底层实现原理，掌握源码分析技巧，助力大家学精学透 Dubbo 的同时，提升微服务架构能力，快速成为独当一面的顶级攻城狮！

  讲师：Allen 中级 184人正在学习

spring4线程池相关教程

• 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. 线程池模型 线程池模型的结构如下：从图中可以看出，线程池模型的程序结构如下：创建一个监听线程，通常会采用 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.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: 线程池中的线程数量，一定要根据该接口所实现的业务需求来设置，设置过多，则会浪费资源空间，设置过少，则不能支撑业务需要，所以配置线程数量一定要谨慎。
• 6. 子线程调试 上面的例子是多线程程序，使用 ThreadPoolExecutor 同时起 3 个线程， submit() 提交任务到线程池不是阻塞的，而是立即返回。当主线程启动了子线程后，会在多线程窗口看到系统自动创建的线程名。当调试进入到各个线程的子程序时，Frame 会自动切换到其所对应的 frame，相应的变量栏中也会显示与该过程对应的相关变量, 使用 setp in，step over 便可以在各自的子线程进行调试了。
• 4. 主从多线程模型 架构图分析：主要分为三个模块，分别为 Reactor 主线程、Reactor 子线程、Worker 线程池。其中 Reactor 主线程可以对应多个 Reactor 子线程，也就是说，一个 MainReactor 对应多个 SubReactor；Reactor 主线程的 MainReactor 对象通过 select 监听客户端连接事件，收到事件之后，通过 Acceptor 处理连接事件；当 Acceptor 处理连接事件之后，MainReactor 将连接事件分配给 Reactor 子线程的 SubReactor 进行处理；SubReactor 将连接加入到连接队列进行监听，并且创建 Handler 处理对应的事件。一旦有新的事件（非连接）则分配给 Handler 进行处理；Handler 通过 read () 方法读取数据，并且分发给 Worker 线程池去做业务处理；Worker 线程池分配线程去处理业务，处理完成之后把结果返回给 Handler；Handler 收到 Worker 线程返回的结果之后，再通过 send () 方法返回给客户端。方案的优点：责任明确，单一功能拆分的更细，Reactor 主线程负责接收请求，不负责处理请求；Reactor 子线程负责处理请求。并发量很高的情况，可以减轻单个 Reactor 的压力，并且提高处理速度；Reactor 子线程只负责读取数据和响应数据，耗时的业务处理则丢给 Worker 线程池去处理。这种通过把完整任务层层分发下去，每个组件需要处理的内容就会变的很简单，处理起来效率自然会很高。方案的缺点：编程复杂度非常的高；即使一个 Reactor 主线程对应多个 Reactor 子线程，Reactor 主线程还是会存在单节点故障问题，不过真实业务场景当中，如果考虑单节点故障问题的话，一般都是通过分布式集群（Netty 集群）的方式去解决，而不是靠单节点的线程模型去解决，这里大家了解一下即可。总的来说，主从多线程模型是应用比较多的一种线程模型，包括 Nginx 主从 Reactor 多线程模型、Memcached 主从多线程模型、Netty 主从多线程模型等知名开源框架的。

spring4线程池相关搜索

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

查看更多慕课网实用课程