Java 并发 线程状态转换 新建(New) 创建后尚未启动。 可运行(Runnable) 可能正在运行,也可能正在等待 CPU 时间片。 時雨:在 《Java 并发核心知识体系精讲》中,参考 Oracle 官方文档,标注实现多线程方式只有两种:实现 Runnable 接口和继承 Thread 类。 (J.U.C)大大提高了并发性能,AQS 被认为是 J.U.C 的核心。 以下代码模拟了对某个服务的并发请求,每次只能有 3 个客户端同时访问,请求总数为 10。 在 Java 内存模型中,允许编译器和处理器对指令进行重排序,重排序过程不会影响到单线程程序的执行,却会影响到多线程并发执行的正确性。
package lading.java.mutithread;import cn.hutool.core.date.DateTime;import java.util.Random;import java.util.concurrent.atomic.AtomicInteger ;import java.util.concurrent.locks.Condition;import java.util.concurrent.locks.ReentrantLock;/** * 模拟生产者 最开始我们学JAVA编程,都是从synchronized开始,线程并发协调,常用的就是对象的wait(),nofity()方法。 今天就分享这么多,目前已分享synchronized、volatile、AQS、CAS、ReentrantLock、Semaphore、CountDownLatch、CyclicBarrier、Condition,并发编程里的基础中的基础已经分享完了 下次我们分享线程池、并发容器、ThreadLocal、Future、FutureTask.
Java中创建线程的三种方法以及区别 Java使用Thread类代表线程,所有的线程对象都必须是Thread类或其子类的实例。 Java可以用三种方式来创建线程,如下所示: 继承Thread类创建线程 实现Runnable接口创建线程 使用Callable和Future创建线程 线程池创建线程 下面让我们分别来看看这三种创建线程的方法 但是编程稍微复杂,如果需要访问当前线程,必须调用Thread.currentThread()方法。 继承Thread类的线程类不能再继承其他父类(Java单继承决定)。 例子一: 单核单处理器,开一个线程跑循环输出10万条打印信息,开100个线程输出10万条打印信息.后者比前者慢,因为输出端是临界资源,线程抢占的时间大,单线程则无需抢占 例子二: 网络服务器处理,每个请求开一个线程 ,请求的处理时间极短,迅速返回,一次提交10万个请求,则有10万次线程创建和销毁对应于一个工作线程处理这10万条请求后者比前者肯定快 注意:多线程并不会提供cpu的执行速度,只是提高了cpu的利用率
以均衡与内存的速度差异 2、操作系统增加了进程、线程,以分时复用cpu,进而均衡cpu与io设备的速度差异 3、编译程序优化指令执行次序,使得cpu缓存能够得到更加合理利用 2)带来的问题(引出三大特性) 现实中的并发问题往往是三种问题的综合症 在解锁的时候,JVM需要强制刷新缓存,使得当前线程所修改的内存对其他线程可见 (3) final 当一个对象包含final修饰的实例字段时,其他线程能够看到已经初始化的final实例字段,这是安全的 二、java 内存模型(两大核心之一) 1)Java内存模型定义了线程和内存的交互方式 在JMM抽象模型中,分为主内存、工作内存。 把从执行引擎接收到的的值赋值给工作内存变量 Store(存储):把工作内存的变量值传递给主内存,以便后续的write使用 Write(写入):用于主内存变量,把store获得的变量的值放入主内存变量 3)内存模型解决并发问题主要采用两种方式
并发与并行 并发指的是同时应对多个事件的能力,并行指的是同时做多件事的能力。 位级并行:32位计算机能够同时处理32位数运算,而8位计算机却要进行多次运算。 java内存模型 java内存类似于SMP,但是其屏蔽了底层硬件环境的差异,给java提供了统一的内存访问模型。 java中所有线程共享主内存,对于每个线程都有自己的工作区,包括寄存器,栈,写换冲区,缓存,硬件,编译优化等。 多线程并发 并发问题也就带来来线程安全访问的问题。多线程执行时需要考虑进行额外的协调。 不可变性:可变数据是引起不安全的主要原因,如果一个数据不可变,则不会存在数据安全问题。 happens-befor:为解决编译器,处理器的重排问题,java引入了happen-befor原则,通过此概念可以定义操作之间内存可见性定义。
并行与并发 单核CPU下,线程实际还是 串行执行 的。 一般会将这种 线程轮流使用 CPU 的做法称为并发(concurrent)。 : 家庭主妇做饭、打扫卫生、洗衣服,她一个人轮流交替做多件事,这时就是并发 家庭主妇雇了一个保姆,她们一起做这些事,这时既有并发、也有并行(这时会产生竞争,例如洗衣机只有一台,一个人用洗衣机时,另一个人只能等待 : sleep interrupted at java.lang.Thread.sleep(Native Method) at io.ray.threadstudy.test.Test10.lambda $main$0(Test10.java:19) at java.lang.Thread.run(Thread.java:748) 08:32:04.201 [main] DEBUG io.ray -
Java并发编程的核心挑战 线程安全与数据竞争 线程安全的概念及其重要性 数据竞争的产生原因及常见场景 如何通过同步机制(如锁、原子类)避免数据竞争 // 示例:使用synchronized关键字实现线程安全 wait(); } buffer.remove(0); notify(); } } } 性能与可伸缩性 并发编程对性能的影响 (4); for (int i = 0; i < 10; i++) { executor.submit(() -> { // 任务逻辑 }); } executor.shutdown (); 并发工具类的使用 Java并发工具类(如CountDownLatch、CyclicBarrier、Semaphore)的应用场景 如何选择合适的工具类解决并发问题 工具类的使用注意事项 // 示例 并发编程的新特性(如CompletableFuture、Flow API) 多核处理器与并发编程的关系 如何应对分布式环境下的并发挑战 // 示例:使用CompletableFuture实现异步编程 CompletableFuture.supplyAsync
> tab[] = table; 9 int hash = key.hashCode(); 10 int index = (hash & 0x7FFFFFFF) % tab.length () Collections类下的synchronized* 方法可以将不安全的集合变成线程安全的集合 例如: 1 Collections.synchronizedMap(new HashMap<>(10 这个机制允许任意数量的读线程可以并发访问Map,读者和写者也可以并发访问Map,并且有限数量的写进程还可以并发修改Map,结果是为并发访问带来更高的吞吐量,同时几乎没有损失单个线程访问的性能。 并发队列 2.1.ConcurrentLinkedQueue ConcurrentLinkedQueue:是一个适用于高并发场景下的队列,通过无所的方式,实现了高并发状态下的高性能,通常ConcurrentLinkedQueue 在Java中,BlockingQueue的接口位于java.util.concurrent 包中(在Java5版本开始提供),由上面介绍的阻塞队列的特性可知,阻塞队列是线程安全的。
本章将着重介绍Java并发编程的基础知识,从启动一个线程到线程间不同的通信方式,最后通过简单的线程池示例以及应用(简单的Web服务器)来串联本章所介绍的内容。 (3)更好的编程模型 Java为多线程编程提供了良好、考究并且一致的编程模型,使开发人员能够更加专注于问题的解决,即为所遇到的问题建立合适的模型,而不是绞尽脑汁地考虑如何将其多线程化。 一旦开发人员建立好了模型,稍做修改总是能够方便地映射到Java提供的多线程编程模型上。 在Java线程中,通过一个整型成员变量priority来控制优先级,优先级的范围从1~10,在线程构建的时候可以通过setPriority(int)方法来修改优先级,默认优先级是5,优先级高的线程分配时间片的数量要多于优先级低的线程 : 10, Count : 1261705 Job Priority : 10, Count : 1259967 从输出可以看到线程优先级没有生效,优先级1和优先级10的Job计数的结果非常相近,没有明显差距
1.并发编程基础 1.1 基本概念 CPU核心与线程数关系 Java中通过多线程的手段来实现并发,对于单处理器机器上来讲,宏观上的多线程并行执行是通过CPU的调度来实现的,微观上CPU在某个时刻只会运行一个线程 但对于一些要求同时进行并且又要共享某些变量的并发操作,只能用线程,不能用进程。 优缺点:线程和进程在使用上各有优缺点:线程执行开销小,但不利于资源的管理和保护;而进程正相反。 并行和并发 并行:同一时刻,可以同时处理事情的能力。 并发:与单位时间相关,在单位时间内可以处理事情的能力。 高并发编程的意义和注意事项 意义和好处:充分利用cpu的资源、加快用户响应的时间,程序模块化,异步化 问题。 可以用setPriority方法来设定线程的优先级,优先级在MIN_PRIORITY(1)和MAX_PRIORITY(10)之间。
而我在代码上写的是: a=10; b=200; result=a*b; 但是到了CPU上的乱序执行优化后,可能就变成了: b=200; a=10; result=a*b; 如下图: ? ---- Java内存模型 以上我们简单介绍了在多核并发的环境下CPU进行乱序执行优化时所带来的线程安全问题,为了保证线程安全,我们需要采取一些额外的手段去防止这种问题的发生。 不过在介绍如何采用实际手段解决这种问题之前,我们先来看看Java虚拟机是如何解决这种问题的:为了屏蔽各种硬件和操作系统内存的访问差异,以实现让Java程序在各种平台下都能达到一致的并发效果,所以Java 这意味着,如果你的Java程序是多线程的,在你的Java程序中每个CPU上一个线程可能同时(并发)执行。 ---- 并发的风险与优势 ?
5 并发容器 5.1 Hashtable、HashMap、TreeMap、HashSet、LinkedHashMap 在介绍并发容器之前,先分析下普通的容器,以及相应的实现,方便后续的对比。 6 return; 7 } 8 9 Entry[] newTable = new Entry[newCapacity]; //初始化一个新的Entry数组 10 7: src[j] = null; 8: do { 9: Entry next = e.next; // Thread1 STOPS RIGHT HERE 10 concurrencyLevel 并发度:默认16。 在高并发下的情况下如何保证取得的元素是最新的?
} }}// 在主线程中启动一个Daemon线程Thread daemonThread = new DaemonThread();daemonThread.start();31、Java Object();public void increment() { synchronized (lock) { int count = 0; while (count < 10 乐观锁认为并发操作过程中数据不会被修改,因此不需要加锁,而是使用版本号或其他标识来判断数据是否正确。悲观锁则认为并发操作过程中数据可能会被修改,因此每次操作都需要加锁,以避免数据不一致的问题。 区别在于 SynchronizedMap 使用了锁来保证并发安全性,而 ConcurrentHashMap 则使用了分段锁技术来提高并发性能。 servlet 是线程安全的,因为它是通过 Java Servlet API 提供的 Servlet 容器来管理的,容器会对每个 Servlet 实例进行隔离和同步,保证了多个线程同时访问 Servlet
Table of Content 计算机基础 java的原子性操作 java的线程通信 java锁机制 reference 计算机基础 Bus 总线的概念 image.png 总线(Bus)是计算机各种功能部件之间传送信息的公共通信干线 也就是在任意的时间点, 最多只能有一个处理器可以访问内存, 这个特性确保总线事务之中的内存读写操作具有原子性 java不对long和double类型数据保持原子性, 是因为他们都是8个字节, 64位 , 对32位机器可能会把64拆成两个32, 从而进入不同的事务里,因此很难保证原子性操作 java的原子性操作 java的原子性操作是靠锁和循环的CAS来实现的 java的线程通信 java的线程通信是靠 共享内存 和 消息通信 来是实现的 java锁机制 java的轻量级锁 volatile: 使用了锁的happen-before 原则 锁的happen-before原则保证释放锁和获取锁的两个线程之间的内存可见性 插入内存屏障的目的就是禁止编译器和处理器的重排序 reference java并发编程的艺术
ThreadLocal 对于多任务,Java 标准库提供的线程池可以方便地执行这些任务,同时复用线程。那么如何在一个线程内传递状态? Java 标准库提供了一个特殊的 ThreadLocal,它可以在一个线程中传递同一个对象。 DEMO ThreadLocal SimpleDateFormat /** * 10 个线程执行 1000 次打印格式化日期,每个线程有自己的格式化对象 */ public class ThreadLocalNormalUsage03 { private static ExecutorService threadPool = Executors.newFixedThreadPool(10); private static
CountDownLatch 中 count down 是倒数的意思,latch 则是门闩的含义。整体含义可以理解为倒数的门栓,似乎有一点“三二一,芝麻开门”的感觉。
B str b set value str=b,num=20 线程异步执行 12:并发脏读问题 脏读:脏读又称无效数据的读出,是指在数据库访问中,事务T1将某一值修改,然后事务T2读取该值,此后T1 at com.atkk.thread.ThreadException2.lambda$main$0(ThreadException2.java:14) at java.lang.Thread.run (Thread.java:748) 准备获取锁....Thread-1 获取到锁....Thread-1 Exception in thread "Thread-1" java.lang.RuntimeException at com.atkk.thread.ThreadException2.lambda$main$0(ThreadException2.java:14) at java.lang.Thread.run (Thread.java:748) 用Lock会好点。
21、CycliBarriar 和 CountdownLatch 都是 Java 并发编程中的线程同步工具。 在写并发应用时,使用不可变对象可以提高性能和避免出现数据竞争的问题。因为如果一个对象被多个线程同时修改,那么就可能会发生数据错乱的情况。因此,使用不可变对象可以保证线程安全。 Java 中的线程调度算法有多种,包括先来先服务、最短作业优先、轮转调度等。具体使用哪种算法取决于系统的硬件资源和应用程序的需求。 在 Java 中,我们可以使用 ThreadGroup 类来创建和管理线程组。 t2); group.addThread(t3); for (Thread thread : group.getThreads()) { thread.start(); } 25、线程组是 Java
Java并发编程:synchronized 虽然多线程编程极大地提高了效率,但是也会带来一定的隐患。比如说两个线程同时往一个数据库表中插入不重复的数据,就可能会导致数据库中插入了相同的数据。 在单线程中不会出现线程安全问题,而在多线程编程中,有可能会出现同时访问同一个资源的情况,这种资源可以是各种类型的的资源:一个变量、一个对象、一个文件、一个数据库表等,而当多个线程同时访问同一个资源的时候 基本上所有的并发模式在解决线程安全问题时,都采用“序列化访问临界资源”的方案,即在同一时刻,只能有一个线程访问临界资源,也称作同步互斥访问。 另外,每个类也会有一个锁,它可以用来控制对static数据成员的并发访问。 参考资料: 《Java编程思想》 http://ifeve.com/synchronized-blocks/ http://ifeve.com/java-synchronized/ http:
线程A .10. 线程B .10. 线程B .10. : Queue full at java.util.AbstractQueue.add(AbstractQueue.java:98) at java.util.concurrent.ArrayBlockingQueue.add (ArrayBlockingQueue.java:312) at com.atkk.thread.BlockingQueueDemo.main(BlockingQueueDemo.java:20) ; import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.BlockingQueue; import java.util.concurrent.SynchronousQueue