为什么要用线程池？ 诸如 Web 服务器、数据库服务器、文件服务器或邮件服务器之类的许多服务器应用程序都面向处理来自某些远程来源的大量短小的任务。请求以某种方式到达服务器，这种方式可能是通过网络协议（例如 HTTP、FTP 或 POP）、通过 JMS 队列或者可能通过轮询数据库。不管请求如何到达，服务器应用程序中经常出现的情况是：单个任务处理的时间很短而请求的数目却是巨大的。 构建服务器应用程序的一个过于简单的模型应该是：每当一个请求到达就创建一个新线程，然后在新线程中为请求服务。实际上，对于原型开发这种方
Java1.5提供了一个非常高效实用的多线程包:java.util.concurrent, 提供了大量高级工具,可以帮助开发者编写高效、易维护、结构清晰的Java多线程程序。
1 458 views A+ 所属分类：未分类 本文相关下载： · Jack 的 HashMap 测试 · Oracle JDeveloper 10g 所有键值对 — 参见 entrySet() 所有键 — 参见 keySet() 有值 — 参见 values() 前两个视图均返回 Set 对象，第三个视图返回 Collection 对象。就这两种情况而言，问题到这里并没有结束，这是因为您无法直接迭代 Collection 对象或 Set 对象。要进行迭代，您必须获得一个 Iter
方式一：将类声明为 Thread 的子类。该子类应重写 Thread 类的 run 方法
知识体系图： 1、线程是什么？ 线程是进程中独立运行的子任务。 2、创建线程的方式 方式一：将类声明为 Thread 的子类。该子类应重写 Thread 类的 run 方法 方式二：声明实现 Runn
阻塞队列 (BlockingQueue)是Java util.concurrent包下重要的数据结构，BlockingQueue提供了线程安全的队列访问方式：当阻塞队列进行插入数据时，如果队列已满，线程将会阻塞等待直到队列非满；从阻塞队列取数据时，如果队列已空，线程将会阻塞等待直到队列非空。并发包下很多高级同步类的实现都是基于BlockingQueue实现的。
我们的座右铭：“要好好学习，不然别人只会指着你的鼻子说“你看那个人，除了帅，一无是处。”
HashMap与Hashtable的区别是面试中经常遇到的一个问题。这个问题看似简单，但如果深究进去，也能了解到不少知识。本文对两者从来源，特性，算法等多个方面进行对比总结。力争多角度，全方位的展示二者的不同，做到此问题的终结版。
JDK 1.7 HashMap 采用数组 + 链表的数据结构，多线程背景下，在数组扩容的时候，存在 Entry 链死循环和数据丢失问题。
响应式编程（Reactive Programming / RP）作为一种范式在整个业界正在逐步受到认可和落地，是对过往系统的业务需求理解梳理之后对系统技术设计/架构模式的提升总结。Java作为一个成熟平台，对于趋势一向有些稳健的接纳和跟进能力，有着令人惊叹的生命活力：
细心的同学一定会发现 ：以无参数构造方法创建 ArrayList 时，实际上初始化赋值的是一个空数组。当真正对数组进行添加元素操作时，才真正分配容量。即向数组中添加第一个元素时，数组容量扩为 10。下面在我们分析 ArrayList 扩容时会讲到这一点内容！
每500ms统计一次gc情况，共执行200次。jstat -gc 262968 500 200
https://blog.csdn.net/zxh87/article/details/52137335
业务一切正常，突然收到一堆告警，发现全是 java.util.concurrent.RejectedExecutionException异常报错。 具体看了下代码，里面的执行逻辑也不难，没有外部依赖都是内存多线程cpu类型计算的逻辑。 下面是报错的线程池状态变化，由上到下，按照时间增长，最后达到饱和。
CyclicBarrier通常称为循环屏障。它和CountDownLatch很相似，都可以使线程先等待然后再执行。不过CountDownLatch是使一批线程等待另一批线程执行完后再执行；而CyclicBarrier只是使等待的线程达到一定数目后再让它们继续执行。故而CyclicBarrier内部也有一个计数器,计数器的初始值在创建对象时通过构造参数指定,如下所示：
同样，也有一些工具可以很方便的对线程的stack信息进行可视化的分析： fastthread就是一个在线分析线程stack的工具 fastthread使用界面：
ThreadPoolExecutor通过execute方法提交任务，任务执行过程中出现异常，会导致线程退出，异常信息即堆栈由标准错误(System.err)输出。
Vector实现List接口，底层和ArrayList类似，但是Vector中的方法都是使用synchronized修饰，即进行了同步的措施。 但是，Vector并不是线程安全的。
因此，CompletableFuture的异步任务如果超时异常try掉了，是不会停止执行的
这一步，就是等待队列为非空的时候，才会执行下去，但是现在队列一直为空，线程都在等待。
在很早之前的文章服务端性能优化之异步查询转同步介绍了一种常用到，服务端开发常用到的多个异步查询转同步的方法，本质上就是利用了java.util.concurrent.CountDownLatch的功能特性，将几个异步查询任务都设置一个java.util.concurrent.CountDownLatch实例，然后等待所有异步任务完成再组装响应，同步返回给客户端。
集合的线程安全 1 ArrayList线程不安全 1.1 ArrayList线程不安全演示 1.2 解决ArrayList线程不安全 1.2.1 解决方案-Vector 1.2.2 解决方案-Collections 1.2.3 解决方案:CopyOnWriteArrayList(写时复制技术 推荐) 2 HashSet线程不安全 2.1 HashSet线程不安全演示 2.2 解决方案：CopyOnWriteArraySet 3、HashMap线程不安全 3.1 HashMap线程不安全演示 3.2
有些时候我们需要查看下jvm中的线程执行情况，比如，发现服务器的CPU的负载突然增高了、出现了死锁、死循环等，我们该如何分析呢？ 由于程序是正常运行的，没有任何的输出，从日志方面也看不出什么问题，所以就需要看下jvm的内部线程的执行情况，然后再进行分析查找出原因。 这个时候，就需要借助于jstack命令了，jstack的作用是将正在运行的jvm的线程情况进行快照，并且打印出来。 jstack是jdk自带的线程堆栈分析工具，使用该命令可以查看或导出 java 应用程序中线程堆栈信息。 jstack用于生成java虚拟机当前时刻的线程快照。线程快照是当前java虚拟机内每一条线程正在执行的方法堆栈的集合，生成线程快照的主要目的是定位线程出现长时间停顿的原因，如线程间死锁、死循环、请求外部资源导致的长时间等待等。 线程出现停顿的时候通过jstack来查看各个线程的调用堆栈，就可以知道没有响应的线程到底在后台做什么事情，或者等待什么资源。 如果java程序崩溃生成core文件，jstack工具可以用来获得core文件的java stack和native stack的信息，从而可以轻松地知道java程序是如何崩溃和在程序何处发生问题。另外，jstack工具还可以附属到正在运行的java程序中，看到当时运行的java程序的java stack和native stack的信息, 如果现在运行的java程序呈现hung的状态，jstack是非常有用的。
AtomicStampReference 解决CAS的ABA问题 什么是ABA ABA问题：指CAS操作的时候，线程将某个变量值由A修改为B，但是又改回了A，其他线程发现A并未改变，于是CAS将进行值交换操作，实际上该值已经被改变过，这与CAS的核心思想是不符合的 ABA解决方案 每次变量更新的时候，把变量的版本号进行更新，如果某变量被某个线程修改过，那么版本号一定会递增更新，从而解决ABA问题 AtomicReference 演示ABA问题 package com.keytech.task; impo
关于并发方面的，juc已帮我们提供了很多好用的工具，而谷歌在此基础上做了扩展，使并发编程更容易，这些工具放在guava.jar包中。
序 本文主要研究一下jvm的Stack Memory Java-Heap-Stack-Memory.png Virtual Machine Stack 每个jvm线程都有一个私有的Virtual Machine Stack，它在线程同时被创建 该stack主要用于存储frames，即所谓的stack frames 每个方法在执行的时候都会创建一个stack frame，用于存储方法的局部变量、返回值、Operand stack等 Stack Memory Stack Memory是执行线程时所使用的内存
1：Spark的官方网址：http://spark.apache.org/ 1：Spark生态系统已经发展成为一个包含多个子项目的集合，其中包含SparkSQL、Spark Streaming、GraphX、MLlib等子项目，Spark是基于内存计算的大数据并行计算框架。Spark基于内存计算，提高了在大数据环境下数据处理的实时性，同时保证了高容错性和高可伸缩性，允许用户将Spark部署在大量廉价硬件之上，形成集群。 2：Spark是MapReduce的替代方案，而且兼容HDFS、Hive，可融入Hado
最近在学习和使用Web3j的过程中，发现一个非常奇怪的现象，当我使用了sendAsync()方法后，JVM进程一直无法退出。
代码示例 import java.util.List; import java.util.concurrent.BlockingQueue; import java.util.concurrent.Callable; import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutorService; import java.util.concurrent.FutureTask; import java.ut
最近在开发批量发送动态push功能的时候，用了线程池提高批量发送的效率，并在线程池任务全部执行完毕后，更新MySQL数据库里接收人的状态信息为已接收状态。主要的业务代码如下：
SimpleDateFormat线程不安全的日期格式化库 SimpleDateFormat是JAVA提供的一个日期转换类。 package com.rumenz.task; import java.text.SimpleDateFormat; import java.util.concurrent.CountDownLatch; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; impor
CyclicBarrier字面意思就是回环栅栏，通过它可以实现让一组线程等待至某个状态之后再全部同时执行。叫做回环是因为当所有等待线程都被释放以后，CyclicBarrier可以被重用。我们暂且把这个状态就叫做barrier，当调用await()方法之后，线程就处于barrier了。
Internal error. Please refer to https://jb.gg/ide/critical-startup-errors
java闭锁用于多个线程共同执行后，统一执行一个动作。比如：多个线程执行计算操作，最后汇总到同一个线程执行汇总计算。需要注意的是，java中的闭锁是仅一次的。当闭锁打开后就会统一执行下面的动作。
为了更好的控制多线程 jdk提供了一套线程框架Executor 帮助开发人员有效地进行线程控制 他们都在java.util.concurrent包中 是jdk并发包的核心 一个重要的类Executors 他扮演线程工厂的角色 通过Executors创建特定功能的线程池 Executors创建线程池方法：
Nacos客户端注册报错：failed to req API__nacos_v1_ns_instance_list after all servers([xxx_8848]) tried_ ErrCode_503, ErrMsg_server is DOWN now, please try again later! 我靠，突然发现服务全都注册不到nacos，但是访问nacos的UI地址又发现nacos是启动着的，并且相关config配置也可以正常显示
这个错误是由于Elasticsearch 6.x版本开始，一个索引只能有一个类型，但是在你的监控索引.monitoring-kibana-6-2023.09.28中，却试图创建两个类型_doc和doc，这是不被允许的。
线程池是一种多线程处理形式，处理过程中将任务添加到队列，然后在创建线程后自动启动这些任务。线程池线程都是后台线程。
很多 Java 工程师在准备面试时，会刷很多八股文，线程和线程池这一块通常会准备线程的状态、线程的创建方式，Executors 里面的一些工厂方法和为什么不推荐使用这些工厂方法，ThreadPoolExecutor 构造方法的一些参数和执行过程等。
Java通过Executors提供四种线程池，分别为： newCachedThreadPool创建一个可缓存线程池，如果线程池长度超过处理需要，可灵活回收空闲线程，若无可回收，则新建线程。 newFixedThreadPool 创建一个定长线程池，可控制线程最大并发数，超出的线程会在队列中等待。 newScheduledThreadPool 创建一个定长线程池，支持定时及周期性任务执行。 newSingleThreadExecutor 创建一个单线程化的线程池，它只会用唯一的工作线程来执行任务，保证所有任务按照指定顺序(FIFO, LIFO, 优先级)执行。
在当今的计算机世界中，多线程编程已经成为了一种重要的技术，它能够充分利用多核处理器和多线程硬件的优点，提高程序的执行效率。Java作为一种流行的编程语言，也提供了丰富的多线程编程支持。
使用java.util.concurrent.ExecutorCompletionService异步处理任务：
生产环境系统excel报表导不出，挨客户投诉，内心慌得一批，赶紧查看日志，结果发现是线程池死锁，这锅真是湿手捏干面，不背也得背了。
并发（concurrent）：即使对于单核CPU，我们也会采用多线程等技术提高service的并发处理能力，我们经常说的高并发，就是这个意思。
在性能测试中，其本质基础就是多线程编程。这其中多线程安全计数是一个很常见的使用场景，在此之前我用的是java.util.concurrent.atomic.AtomicLong或者java.util.concurrent.atomic.AtomicInteger，但是在最近深入学习多线程编程的过程中（随着线程数增加），发现知识又需要增加了。
线程安全性 当多线程访问某个类时,不管运行环境采用何种调度方式或者这些进程将如何交替执行,并且在主调代码中不需要任何的同步或者协同,这个类都能表现出正确的行为,那么这个类就是线程安全的. 原子性 提供互斥访问,同一时刻只有一个线程对它进行访问. Atomic包 位于java.util.concurrent.atomic,AtomicXXX : CAS、Unsafe.compareAndSwapXXX CAS(Compare and swap)比较和替换是设计并发算法用的的一项技术,比较和替换是用一个期望值和
领取专属 10元无门槛券
手把手带您无忧上云
云服务器
ICP备案
对象存储
腾讯会议
实时音视频
