在58同城做网站怎么样,网站建设 代理,重庆微信营销网站建设,网站建设自学建站视频教程你好#xff0c;我是 shengjk1#xff0c;多年大厂经验#xff0c;努力构建 通俗易懂的、好玩的编程语言教程。 欢迎关注#xff01;你会有如下收益#xff1a;
了解大厂经验拥有和大厂相匹配的技术等
希望看什么#xff0c;评论或者私信告诉我#xff01; 文章目录 一…你好我是 shengjk1多年大厂经验努力构建 通俗易懂的、好玩的编程语言教程。 欢迎关注你会有如下收益
了解大厂经验拥有和大厂相匹配的技术等
希望看什么评论或者私信告诉我 文章目录 一、背景二、线程之间通信的基本储备2.1 为什么线程之间需要通信2.2 现代处理器结构2.3 基于现代处理器结构下的线程运行模型2.4 线程工作内存带来的问题 三、volatile 和 synchronized3.1 volatile是什么3.1.1 可见性3.1.2 禁止指令重排序优化3.1.3 内存屏障Memory Barrier3.1.4 不保证原子性3.1.5 使用场景 3.2 volatile 原理和例子3.2 synchronized 是什么3.2.1. 基本用法3.2.1.1 同步方法3.2.1.2 同步代码块 3.2.2. 工作原理3.2.3. 保证原子性和可见性 3.3 synchronized 原理和例子 四、总结 一、背景
前面两篇我们分别知道了 关于 java 多线程你需要知道的一些基础知识 以及 关于 java 多线程你需要知道的一些基础知识 本篇文章呢我们继续死磕 java 多线程来聊一聊 java 多线程之间是如何通信的-volatile 和 synchronized
二、线程之间通信的基本储备
2.1 为什么线程之间需要通信
在线程编程中线程之间需要相互通信的主要原因是协作和数据共享。以下是一些主要的原因 资源共享 多个线程可能需要同时访问和操作共享的资源如数据结构、文件、网络连接等。为了避免数据竞争和确保数据的一致性线程之间需要通信来协调对共享资源的访问。 任务分工 在多线程编程中不同线程可以负责不同的任务或子任务线程之间需要协作和通信以完成整体的工作。通信可以是单向的传达结果也可以是双向的交换信息和状态。 同步操作 线程之间的通信可以用于同步操作例如一个线程需要等待另一个线程完成某个任务后才能继续执行或者通知其他线程某个事件已发生。 数据传递 线程之间通过通信来传递数据和消息以便于协调工作、共享信息或通知事件。 提高性能 在某些情况下通过线程之间的通信和协作可以提高程序的性能例如使用线程池执行并发任务时可以减少线程的创建和销毁开销。 实现某些模型和算法 有些并发模型和算法需要线程之间的协作和通信如生产者消费者模型、并发队列等。
综上所述线程之间的通信在多线程编程中是非常重要的能够实现不同线程之间的协作、数据共享、任务分工等功能从而有效利用计算资源并实现复杂的并发任务。
2.2 现代处理器结构
一般情况下现代处理器通常会包含一级缓存L1 Cache、二级缓存L2 Cache、和三级缓存L3 Cache。这些缓存一般都是集成在处理器芯片内部的被称为“内置缓存”On-Chip Cache用于加快数据的访问速度和减少对主内存的访问。这里有一个 2020年的数据
L1 cache 访问时间是 1ns
L2 cache 访问时间是 4ns
主存访问时间是 100ns具体关于三级缓存L3 Cache通常的情况包括
位置 L3 Cache通常位于处理器芯片内部但是相对于L1和L2 Cache它的容量更大从几MB到几十MB不等。作用 L3 Cache主要用来缓存多个核心之间共享的数据以提高处理器核心之间的数据共享效率。互相之间是否独立 不同处理器核心之间可以访问共享的L3 Cache这有助于提高多个核心之间数据访问的效率。
由于L3 Cache容量较大且能够为多个核心提供共享数据缓存因此它可以有效地提高多核处理器系统中核心之间的数据共享和协作效率。虽然L3 Cache通常也集成在处理器芯片内部但某些处理器架构可能会将部分L3 Cache放置在处理器芯片外部以适应不同的需求。 当系统运行时CPU执行计算的过程如下
程序以及数据被加载到主内存指令和数据被加载到CPU缓存CPU执行指令把结果写到高速缓存高速缓存中的数据写回主内存
2.3 基于现代处理器结构下的线程运行模型 线程的工作内存其实就是多级缓存以及CPU寄存器的抽象。
所以每个线程在运行时确实都会有自己的一套完整的上下文这个上下文包含了线程当前的状态、执行环境以及必要的数据。这个上下文在线程切换时被保存和恢复以确保线程可以从中断点继续执行。下面是上下文的一些重要组成部分 寄存器状态 在上下文中包含了线程当前寄存器的状态。寄存器存储了当前线程的执行环境包括程序计数器、栈指针、各种通用寄存器等。 栈 程序使用的栈包含了函数调用、局部变量以及其他执行环境的信息。每个线程都有自己的栈用于存储执行过程中的临时数据。 程序计数器Program Counter 程序计数器存储着当前执行的指令地址或者是下一条待执行的指令地址。 线程状态 这部分描述了线程当前所处的状态比如运行态、就绪态、阻塞态等。线程状态的改变会触发线程调度。 权限和访问控制 上下文中可能包含了线程的权限信息以确保线程的操作在合适的权限下进行。 堆栈指针信息 记录了当前线程堆栈的指针位置在进行栈操作时起着重要作用。 资源分配信息 上下文还可能包括了线程已获得的资源、线程使用的栈大小等信息。
通过保存和恢复这些上下文信息操作系统能够有效地管理多个线程的执行实现线程之间的切换和并发执行。这些上下文信息是确保线程能够在不同执行环境下正确运行的关键。
2.4 线程工作内存带来的问题
线程有自己的工作内存最大的问题之一就是数据不一致性问题。这种情况可以导致程序出现难以预测的错误行为因为多个线程可能会在各自的工作内存中缓存共享变量的副本而这些副本的更新可能无法即时反映到其他线程中引发数据的不一致性。
数据不一致性问题的一些常见情形包括 写问题Write Problem 一个线程在自己的工作内存中修改了共享变量但未立即写回主内存导致其他线程无法立即看到这个变化。 读问题Read Problem 一个线程从主内存中读取了共享变量的值但由于另一个线程已经对该变量进行了修改该线程的工作内存中的值已经过时导致读取的值不正确。 指令重排序问题 编译器或处理器可能会对指令进行重排序优化这可能导致线程在不同的顺序下访问共享变量进而使得数据出现不一致的情况。
其实就是两类问题
数据可见性的问题即另外一个线程改了共享变量我能不能马上知道。共享变量一致性的问题即多个线程操作同一个共享变量它的结果能不能跟非多线程操作同一个共享变量的结果一致。
为了解决上述的两个问题我们引入了 volatile 和 synchronized
三、volatile 和 synchronized
3.1 volatile是什么
volatile 是 Java 中的一个关键字主要用于确保多线程环境下变量的可见性和有序性。当一个变量被声明为 volatile 时意味着这个变量可能会被多个线程同时访问和修改因此需要使用 volatile 来确保所有线程都能看到变量的最新值。
下面是 volatile 的详细解释
3.1.1 可见性
在多线程环境中一个线程修改了一个共享变量的值另一个线程无法立即看到这个变化除非它主动读取该变量的值。而 volatile 关键字保证了当一个线程修改了一个 volatile 变量的值后其他线程会立即看到这个变化。这是因为 volatile 变量不会被缓存到线程的工作内存中每次读取 volatile 变量时都会直接从主内存中获取最新值。
3.1.2 禁止指令重排序优化
编译器和处理器可能会对代码进行指令重排序优化以提高执行效率。但是在某些情况下这种重排序可能会导致多线程环境下的数据不一致问题。volatile 关键字可以防止这种情况发生它会告诉编译器和处理器不要对这个变量进行重排序优化。
3.1.3 内存屏障Memory Barrier
现代处理器为了提高性能会对内存操作进行优化包括重新排序读写操作。为了强制处理器的操作符合程序员的预期顺序编译器会在使用volatile的读/写操作周围插入内存屏障Memory Barrier。这些内存屏障是一种同步机制用于阻止屏障两侧的指令被重排序。通过确保特定的读写操作顺序执行内存屏障确保了程序中的某些操作在特定时刻已经执行完成或已经启动执行从而在多线程环境中维持操作的有序性。
3.1.4 不保证原子性
虽然 volatile 可以保证可见性和禁止指令重排序优化但它不能保证复合操作如自增或自减等的原子性。如果需要一个变量在多线程环境下的原子性操作如计数或状态更新等应该使用 AtomicInteger 或 AtomicLong 等原子类或者使用 synchronized 块来保证原子性。但对于简单的状态标记例如一个标志位volatile 是足够的。
3.1.5 使用场景
volatile 主要用于以下场景
状态标记例如用于标记某个任务是否已经完成。在这种情况下一个线程会检查这个标记然后基于这个标记的值来决定下一步行动。如果这个标记在多线程环境下被使用并且可能被多个线程同时修改那么就需要使用 volatile 来确保每个线程都能看到最新的标记值。单例模式的双重检查锁定在某些单例模式的实现中会使用 volatile 来确保实例在多个线程间的正确创建和访问。
总的来说volatile 是一个轻量级的同步机制用于确保多线程环境下变量的可见性和有序性。但在需要复杂同步操作或原子性保证的情况下可能需要考虑使用更强大的同步机制如 synchronized 块或锁。
3.2 volatile 原理和例子
volatile 状态标记 的例子
public class StopThreadExample {// 使用volatile修饰的变量来确保所有线程都能看到最新的标志位值private volatile boolean flag true;// 一个任务执行线程它持续检查标志位并根据标志位决定是否继续运行public void runTask() {while (isRunning) { // 使用volatile修饰的变量确保我们能正确读取到最新的状态// 这里模拟一些耗时任务System.out.println(执行任务...);try {Thread.sleep(1000); // 模拟耗时操作这里暂停一秒} catch (InterruptedException e) {e.printStackTrace();}}System.out.println(任务执行线程已经停止.);}public static void main(String[] args) throws InterruptedException {StopThreadExample example new StopThreadExample();Thread taskThread new Thread(() - example.runTask()); // 启动任务执行线程taskThread.start(); // 开始执行任务线程try {TimeUnit.SECONDS.sleep(5);} catch (InterruptedException e) {e.printStackTrace();}; // 让主线程暂停几秒以便观察效果模拟主线程正在做其他事情的情况System.out.println(停止任务执行线程...); // 在主线程中通知任务执行线程停止执行example.flag false; // 设置标志位来停止任务执行线程所有线程都会看到最新的标志位值因为使用了volatile关键字修饰isRunning变量taskThread.join(); // 确保任务执行线程停止后主线程继续执行接下来的代码或结束程序这一步依赖于主线程的下一步动作System.out.println(主线程结束.); // 当任务执行线程已经停止后主线程结束程序或继续其他操作这里模拟主线程的下一步动作}
}在字节码层面 volatile 原理是通过 flags 表示来实现的
3.2 synchronized 是什么
synchronized 是 Java 中用于控制多线程并发访问共享资源的一种关键字。它可以确保多个线程在同一时刻只能有一个线程执行某个代码块或方法从而避免并发问题如竞态条件。以下是关于 synchronized 的详细介绍
3.2.1. 基本用法
3.2.1.1 同步方法
直接在方法声明上使用 synchronized 关键字这样整个方法都在同步块内。例如
public synchronized void synchronizedMethod() {// 同步代码块
}此时该方法只能由一个线程在任何时候访问。多个线程调用此方法时其他线程会被阻塞直到当前线程执行完毕。这种方法的同步锁是当前实例对象即 this。如果要同步的是静态方法锁是类的 Class 对象。
3.2.1.2 同步代码块
可以使用 synchronized(锁对象) 语法创建一个同步代码块。例如
synchronized (lockObject) {// 同步代码块内容
}此时只有持有锁对象的线程可以进入该代码块。多个线程可以尝试访问这个同步块但只有一个能获得锁并执行其中的代码。其他线程会被阻塞直到锁被释放。锁对象可以是任何对象通常是一个自然存在的共享资源或者一个特定的锁对象。当锁对象是 this 时相当于同步整个方法。如果锁对象是某个静态变量那么任何线程调用这段代码都需要获得那个锁才能执行。但一定要确保使用的锁对象不会在方法中频繁变化。如果对象在不同的上下文中表示不同的资源或意义则可能导致意外的并发问题。
3.2.2. 工作原理
当一个线程进入一个 synchronized 代码块或方法时它首先尝试获取锁对象对应的内置锁也称为监视器锁。如果锁已经被另一个线程持有那么该线程将会进入等待状态直到锁被释放由持有锁的线程退出同步块或调用 wait() 方法。这种机制确保了同一时刻只有一个线程可以访问同步代码块或方法中的共享资源。一旦线程释放锁退出同步块或方法其他等待的线程将有机会尝试获取该锁并执行相应的代码。如果多个线程同时尝试获取同一个对象的锁它们会被按照某种顺序来串行化地执行同步代码块或方法。值得注意的是同步控制开销通常比上下文切换的开销要小得多。此外JVM 会尝试优化锁的获取和释放过程以提高性能。对于复杂的应用场景还有专门的性能调优和死锁避免策略可用。
3.2.3. 保证原子性和可见性
是的我的解释是正确的。在 Java 中使用 synchronized 关键字时确实涉及到内存模型和工作内存与主内存的刷新问题特别是在多线程环境下。让我们再次详细解释这一点。
当你在 Java 程序中使用 synchronized 块时这个关键字确保了多个线程对共享资源的同步访问。这是通过确保只有一个线程能够获取到锁来实现的。在这个同步块内所有的读写操作都是对该锁对象的原子操作。这就意味着当一个线程进入 synchronized 块时它会获取锁对象并开始执行同步块内的代码。此时其他尝试进入该同步块的线程会被阻塞直到持有锁的线程释放锁为止。
在这个过程中涉及到内存模型和工作内存与主内存的交互
互斥访问当一个线程进入 synchronized 块时它需要获得锁。只有获得锁的线程才能执行同步块内的代码从而保证了同一时刻只有一个线程在操作共享变量。工作内存与主内存的刷新当一个线程持有锁并执行同步块内的操作时它会首先从主内存中读取共享资源到工作内存中即线程的本地缓存。在工作内存中修改这些数据后只有当线程释放锁并允许其他线程获取锁时这些修改才会被写回主内存。这就意味着同步块内的操作保证了在工作内存中对共享数据的操作在所有线程之间是一致的。缓存一致性在多线程环境中缓存一致性是确保多个线程之间共享的数据保持一致性的过程。synchronized 块确保了在任何时候只有一个线程能够修改共享数据从而避免了缓存不一致的问题。即使其他线程尝试读取或写入共享数据由于它们被阻塞在锁之外它们不能看到在工作内存中的修改除非持有锁的线程释放锁并允许它们获取锁。
简而言之synchronized 通过确保对共享资源的独占访问来强制工作内存与主内存的刷新从而保证了缓存一致性。它确保了任何线程在访问或修改共享数据时都是实时的并且一致的。
3.3 synchronized 原理和例子
public class Counter {private int count 0; // 共享资源计数器// synchronized 块用于保护对 count 的并发访问public synchronized void increment() {count; // 对共享资源的操作这里是增加计数器的值}public int getCount() {return count; // 外部访问共享资源可能需要同步}public static void main(String[] args) throws InterruptedException {Counter counter new Counter(); // 创建 Counter 实例对象// 创建多个线程模拟并发增加计数器的值for (int i 0; i 10; i) { // 创建 10 个线程来并发增加计数器的值Thread thread new Thread(() - {for (int j 0; j 100; j) { // 每个线程都尝试增加计数器值多次以模拟并发情况counter.increment(); // 使用 synchronized 块来安全地增加计数器值}});thread.start(); // 启动线程thread.join();} // 循环结束后所有线程都已经启动并尝试增加计数器的值。由于使用了 synchronized 块计数器的值将准确累积而不会发生冲突或重叠增加的情况。可以检查 getCount() 的返回值来验证这一点。System.out.println(counter.count);}
}
在字节码层面 synchronized 原理 方法同步: 对于使用synchronized修饰的方法JVM会在方法的访问修饰符字节码指令之前插入一个特殊的指令称为“ACC_SYNCHRONIZED”。这个标志告诉JVM该方法需要一个锁来执行。当线程调用这个方法时它必须先获得对象的内置锁即实例锁。持有锁的线程可以在该对象的任何方法上执行任何操作而不会阻塞其他线程对同一个对象的访问。当方法返回时锁会被自动释放。 代码块同步: 对于使用synchronized(obj)修饰的代码块Java编译器会在该代码块的起始和结束位置生成特定的字节码指令。具体来说它会使用monitorenter和monitorexit指令。monitorenter指令用于获取对象的内部锁而monitorexit指令用于释放该锁。这两个指令确保了同步代码块中的代码是原子的并且不会被其他尝试获取同一锁的线程中断。如果在持有锁的过程中发生了异常需要确保monitorexit指令始终被执行以释放锁。
四、总结
在多线程编程中线程之间的通信非常重要它可以实现资源共享、任务分工、同步操作、数据传递和提高性能等功能。为了确保线程之间的通信的正确性和效率可以使用volatile关键字和synchronized关键字。volatile关键字可以保证可见性和禁止指令重排序优化而synchronized关键字可以保证对共享资源的同步访问保证原子性和可见性。
