spring线程封闭

spring线程封闭相关知识

• 源码|从串行线程封闭到对象池、线程池

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

  1 线程封闭多线程访问共享可变数据时，涉及到线程间数据同步的问题。并不是所有时候，都要用到 共享数据，所以线程封闭概念就提出来了。数据都被封闭在各自的线程之中，就不需要同步，这种通过将数据封闭在线程中而避免使 用同步的技术称为线程封闭。避免并发异常最简单的方法就是线程封闭 即 把对象封装到一个线程里,只有该线程能看到此对象; 那么该对象就算非线程安全,也不会出现任何并发安全问题.1.1 栈封闭局部变量的固有属性之一就是封闭在线程中。 它们位于执行线程的栈中，其他线程无法访问这个栈1.2 使用ThreadLocal是实现线程封闭的最佳实践.ThreadLocal是Java里一种特殊的变量。 它是一个线程级变量，每个线程都有一个ThreadLocal, 就是每个线程都拥有了自己独立的一个变量, 竞争条件被彻底消除了，在并发模式下是绝对安全的变量。用法ThreadLocal<T> var = new ThreadLocal<T>(
• JAVA高逼格面试：线程封闭

  码农的世界从来不缺乏名词。如果没有，我们就强行弄上几个。这些名词有垂直领域的知识缩写，也有水平领域的抽象划分。有的行云流水无比顺畅，有的晦涩难懂如便秘。在java的并发编程里，就有一个比较晦涩的名词，叫做线程封闭。在以往的技术交流中，经常有人提到这个东西。那它到底是何方神圣，又有什么用的功效呢？你去搜索一下网络上的文章，都会给你三个选项。1）Ad-hoc线程封闭。2）栈封闭。3）ThreadLocal类。这些知识，戳破了那层窗户纸，内容其实并不复杂。可怕的是这些名词，为了记住它们真是蛋碎了一地。意义？我们都知道，一个变量如果被多个线程所使用，势必会引入同步问题。除了同步关键字，java引入了多种技术来达到多线程的同步问题，包括wait、notify，可重入Lock，AQS等。这种编程方式会增加程序的复杂性，使得代码容易发生bug。如果有一些数据，仅仅和线程有关，对线程外的数据是不可见的，那代码写起来就美好的多。实现了这种效果的技术，就统一称为线程封闭（thread  confinement）。这是
• Spring多线程批量发送邮件（ThreadPoolTaskExecutor）

  1，需求：使用多线程批量发送邮件需要批量发送邮件大概400封左右，但是因为发送邮件受网络限制，所以经常导致等待超时。所以就想到了使用多线程来发邮件，因为是异步的所以返回结果不受发邮件影响。2，思路：使用spring的ThreadPoolTaskExecutor，用10个线程循环400个任务，完成任务后关闭首先创建一个发邮件的Task(任务)，只是负责发邮件。然后创建一个执行任务的类，让ThreadPoolTaskExecutor循环执行创建一个ThreadPoolTaskExecutor的bean配置交给spring管理3，代码：SendEmailTask.java(任务类) SendEmailThread.java(执行任务类) email.xml(ThreadPoolTaskExecutor的配置)SendEmailTask.java:package com.XXX.core.base.utils.task;import com.XXX.core.base.uti

spring线程封闭相关课程

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

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

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

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

• Spring Boot2.0深度实践 核心原理拆解+源码分析 课程系统性地深度探讨 Spring Boot 核心特性，引导小伙伴对 Java 规范的重视，启发对技术原理性的思考，掌握排查问题的技能，以及学习阅读源码的方法和技巧，全面提升研发能力，进军架构师队伍。

  讲师：小马哥 高级 2789人正在学习

spring线程封闭相关教程

• 3. 每线程模型 下图展示了每线程模型的结构。从图中可以看出，每线程模型的程序结构如下：创建一个监听线程，通常会采用 Java 主线程作为监听线程。创建一个 java.net.ServerSocket 实例，调用它的 accept 方法等待客户端的连接。当有新的客户端和服务器建立连接，accept 方法会返回，创建一个新的线程和客户端通信。此时监听线程返回，继续调用 accept 方法，等待新的客户端连接。在新线程中调用 java.net.Socket 的 recv 和 send 方法和客户端进行数据收发。当数据收发完成后，调用 java.net.Socket 的 close 方法关闭连接，同时线程退出。下来，我们通过一个简单的示例程序演示一下每线程模型服务器的编写方法。示例程序的基本功能如下：客户端每隔 1 秒向服务器发送一个消息。服务器收到客户端的消息后，向客户端发送一个响应消息。客户端发送完 10 个消息后，关闭 Socket 连接，程序退出。服务器检测到客户端关闭连接后，同样关闭 Socket 连接，并且负责和客户端通信的线程也退出。客户端代码：import java.io.*;import java.net.InetSocketAddress;import java.net.Socket;import java.net.SocketAddress;public class TCPClientMultiThread { // 服务器监听的端口号 private static final int PORT = 56002; // 连接超时时间 private static final int TIMEOUT = 15000; // 客户端执行次数 private static final int TEST_TIMES = 10; public static void main(String[] args) { Socket client = null; try { // 测试次数 int testCount = 0; // 调用无参构造方法 client = new Socket(); // 构造服务器地址结构 SocketAddress serverAddr = new InetSocketAddress("192.168.0.101", PORT); // 连接服务器，超时时间是 15 毫秒 client.connect(serverAddr, TIMEOUT); System.out.println("Client start:" + client.getLocalSocketAddress().toString()); while (true) { // 向服务器发送数据 DataOutputStream out = new DataOutputStream( new BufferedOutputStream(client.getOutputStream())); String req = "Hello Server!"; out.writeInt(req.getBytes().length); out.write(req.getBytes()); // 不能忘记 flush 方法的调用 out.flush(); System.out.println("Send to server:" + req); // 接收服务器的数据 DataInputStream in = new DataInputStream( new BufferedInputStream(client.getInputStream())); int msgLen = in.readInt(); byte[] inMessage = new byte[msgLen]; in.read(inMessage); System.out.println("Recv from server:" + new String(inMessage)); // 如果执行次数已经达到上限，结束测试。 if (++testCount >= TEST_TIMES) { break; } // 等待 1 秒然后再执行 try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } } } catch (IOException e) { e.printStackTrace(); } finally { if (client != null){ try { client.close(); } catch (IOException e) { e.printStackTrace(); } } } }}服务器代码：import java.io.*;import java.net.ServerSocket;import java.net.Socket;public class TCPServerPerThread implements Runnable{ private static final int PORT =56002; private Socket sock = null; TCPServerPerThread(Socket sock){ this.sock = sock; } @Override public void run() { // 读取客户端数据 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(); } } } } public static void main(String[] args) { ServerSocket ss = null; try { // 创建一个服务器 Socket ss = new ServerSocket(PORT); while (true){ // 监听新的连接请求 Socket conn = ss.accept(); System.out.println("Accept a new connection:" + conn.getRemoteSocketAddress().toString()); Thread t = new Thread(new TCPServerPerThread(conn)); t.start(); } } catch (IOException e) { e.printStackTrace(); } finally { if (ss != null){ try { ss.close(); } catch (IOException e) { e.printStackTrace(); } } } }}客户端采用单线程模型。服务器采用每线程模型，我们采用实现 Runnable 接口的方式实现多线程逻辑。从示例代码可以看出，每线程模型的优点就是结构简单，相比单线程模型，也没有增加复杂度。缺点就是针对每个客户端都创建线程，当和客户端通信结束后，线程要退出。频繁的创建、销毁线程，对系统的资源消耗比较大，只能用在简单的业务场景下。
• 3. 线程上下文 current_session_context_class 可配置值除 thread 外还有 jta、managed 等，简单描述下：当使用本地 Jdbc 事务时选择 Thread。当使用全局 jta 事务时选择 jta。当使用 session 管理机制时选择 managed；如和 Spring 一起整合使用时，使用 Spring 的事务管理机制。主要聊聊 thread 上下文是如何实现保存 Session，回顾一下上一节课程 HibernateSessionFactory 类中的代码片段：private static final ThreadLocal<Session> threadLocal = new ThreadLocal<Session>();public static Session getSession() throws HibernateException { Session session = (Session)threadLocal.get(); aif(session == null || !session.isOpen()) { session = (sessionFactory!= null) ? sessionFactory.openSession():null; threadLocal.set(session); } return session;}实现的关键就在于 ThreadLocal 这个类，ThreadLocal 是 Java SE 原生 API，此类实例化对象本质就是一个 Map 集合，与 Map 保存数据时不同，key 由线程对象充当。使用此对象可以为每一个线程保存只属于当前线程的数据。HibernateSessionFactory 中重构过的 getSession（） 方法解析如下：以当前线程对象为 key 查询 threadLocal 集合中是否存在 Session 对象，如有直接返回；Session session = (Session) threadLocal.get();return session;如果没有，则创建 Session 对象，用当前线程作为 key 保存 Session 对象到 threadLocal 对象中。if(session == null || !session.isOpen()) { session = (sessionFactory!= null) ? sessionFactory.openSession():null; threadLocal.set(session);}如上面代码所述，只要线程生命周期没走到尽头，与其关联的 Session 对象就能重复使用。并且每一个线程中使用的是与本线程相关联的 Session，避免了多线程环境下 Session 变成临界资源，避开线程安全隐患。
• 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(); } } } }}
• 2.1 buildscript{} 闭包 首先我们先看下上面的buildscript闭包，这个闭包里是配置 Gradle 脚本执行所需要的的依赖，分别是对应 Maven 仓库和构建工具 Gradle 的版本。2.1.1 repositories{} 闭包这个闭包里面主要是配置远程的 Maven 仓库地址。我们看到里面声明了jcenter()和google()，这两个都是 maven 仓库，上面托管了很多开源项目，依赖了这个我们就可以引用上面的开源项目了。比如 Android 中的 V7，V4 包等。2.1.2 dependencies{} 闭包这个闭包我们直接看，就应该能猜到是配置项目构建工具 Gradle 的版本的，classpath 就是声明一个插件 Gradle来构建项目。dependencies虽然是依赖的意思，但是我们这里需要注意：不能将应用程序的依赖放在这里，应用程序的依赖在单独的build.gradle里面。
• 浏览器的多线程和单线程 学习过 JavaScript 的可能会了解，JavaScript 的宿主浏览器只有一个线程运行 JavaScript，除了 JavaScript 的线程，浏览器中单个页面还有一些其他线程，例如：UI 线程负责处理渲染 DOM 元素；GUI 线程用于处理与用户交互的逻辑；网络线程用于发送接收 HTTP 请求；file 线程用于读取文件；定时器线程处理定时任务等等。
• 6. 守护线程的作用及使用场景 作用：我们以 GC 垃圾回收线程举例，它就是一个经典的守护线程，当我们的程序中不再有任何运行的 Thread, 程序就不会再产生垃圾，垃圾回收器也就无事可做，所以当垃圾回收线程是 JVM 上仅剩的线程时，垃圾回收线程会自动离开。它始终在低级别的状态中运行，用于实时监控和管理系统中的可回收资源。应用场景：为其它线程提供服务支持的情况，可选用守护线程；根据开发需求，程序结束时，这个线程必须正常且立刻关闭，就可以作为守护线程来使用；如果一个正在执行某个操作的线程必须要执行完毕后再释放，否则就会出现不良的后果的话，那么这个线程就不能是守护线程，而是用户线程；正常开发过程中，一般心跳监听，垃圾回收，临时数据清理等通用服务会选择守护线程。

spring线程封闭相关搜索

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

查看更多慕课网实用课程