Java提供了强制原子性的内置锁机制:synchronized块。
一个synchronized块有两部分:
锁对象的引用,以及这个锁保护的代码块。
每个Java对象都可以隐式地扮演一个用于同步的锁的角色;这些内置的锁被称为内部锁或监听器锁。执行线程进入synchronized块之前会自动获得锁;而无论通过正常控制路径退出,还是从块中抛出异常,线程都在放弃对synchronized块的控制时自动释放锁。获得内部锁的唯一途径是:进入这个内部锁保护的同步块或方法。
内部锁在Java中扮演了互斥锁的角色。
重进入:
当一个线程请求其他线程已经占有的锁时,请求线程将被阻塞。然而内部锁是可重进入的,因为线程在试图获得它自己占有的锁时,请求会成功。
重进入意味着所有的请求是基于“每个线程”,而不是基于“每个调用”的。
重进入方便了锁行为的封装,因此简化了面向对象并发代码。否则子类复写父类的synchronized类型的方法,并调用父类中的方法,那么就会产生死锁了。
你不可以将一个原子操作分解到多个synchronized块中。不过你应该尽量从synchronized块中分离耗时的且不影响共享状态的操作。
public void service(ServletRequest req, ServletResponse resp) {
BigInteger i = extractFromRequest(req);
BigInteger[] factors = null;
synchronized (this) {
++hits;
if (i.equals(lastNumber)) {
++cacheHits;
factors = lastFactors.clone();
}
}
if (factors == null) {
factors = factor(i);
synchronized (this) {
lastNumber = i;
lastFactors = factors.clone();
}
}
encodeIntoResponse(resp, factors);
}
请求与释放锁的操作需要开锁,所以将synchronized块分解得过于琐碎是不合理的,即使这样做是为了获得更好的原子性。当访问状态变量或者执行复合操作期间,CachedFactorizer会占有锁,但是执行潜在耗时的因数分解之前,它会释放锁。这样即保护了线程安全性,也不会过多地影响并发性。
public class NoVisibility {
private static boolean ready;
private static int number;
private static class ReaderThread extends Thread {
public void run() {
while (!ready)
Thread.yield();
System.out.println(number);
}
}
public static void main(String[] args) {
new ReaderThread().start();
number = 42;
ready = true;
}
}
Novisibility可能会一直保持循环,因为对于读线程来说,ready的值可能永远不可见。甚至可能会打印0,因为早在number赋值之前,主线程就已经写入ready并使之对读取线程可见,这是一种重拍序现象。读线程看到的顺序可能与发生写入的顺序正好相反,或者完全不同。
在没有同步的情况下,编译器,处理器,运行时安排操作的执行顺序可能完全出人意料。在没有进行适当同步的多线程程序中,尝试推断那些“必然”发生在内存中的动作时,你总是会判断错误。
有一个简单的方法来避免这些复杂的问题:只要数据需要被跨线程共享,就进行恰当的同步。
编写正确的并发程序的关键在于对共享的、可变的状态进行访问管理。
非原子的64位操作
JVM允许将64位的读或写划分为两个32位的操作。如果读和写发生在不同的线程,这种情况读取一个非volatile类型long就可能会出现得到一个值的高32位和另一个值的低32位。伪共享。
Volatile变量
当一个域声明为volatile类型后,编译器与运行时会监视这个变量,它是共享的,而且对它的操作不会与其他的内存操作一起被重排序。Volatice变量不会缓存在寄存器或者缓存在对其他处理器隐藏的地方。所以,读一个volatile类型的变量时,总会返回由某一线程所写入的最新值。
然而访问volatile变量的操作不会加锁,也就不会引起执行线程的阻塞,这使得volatile变量相对于synchronized而言,只是轻量级的同步机制。
正确使用volatile变量的方式包括:用于确保它们所引用的对象的状态的可见性,或者用于标识重要的生命周期事件的发生。
下面的例子示范了一种volatile变量的典型应用;检查状态标记,以确定是否退出一个循环。Asleep标记就必须是volatile的,否则执行检查的线程不会注意到asleep已被其他线程修改。
volatile boolean asleep;
...
while (!asleep)
countSomeSheep();
注意volatile的语义不足以使自增操作原子化,原子变量提供了“读改写”原子操作的支持,而且常被用作更优的volatile变量。
加锁可以保证可见性与原子性,volatile变量只能保证可见性。
只有满足了下面所有的标准后,你才能使用volatile变量:
1. 写入变量时并不以来变量的当前值;或者能够确保只有单一的线程修改变量的值。
2. 变量不需要与其他的状态变量共同参与不变约束。
3. 而且,访问变量时,没有其他的原因需要加锁。
发布和逸出
一个对象在尚未准备好时就将它发布,这种情况叫做逸出。
class UnsafeStates {
private String[] states = new String[] {
"AK", "AL" ...
};
public String[] getStates() { return states; }
}
以上面这种方式发布states会出现问题。任何一个调用者都能够修改它的内容。这个例子中states已经逸出它所属的范围。
线程封闭
线程封闭技术是实现线程安全的最简单方式之一。
ThreadLocal
它允许你将每个线程与持有数据的对象关联在一起。通过利用ThreadLocal存储JDBC连接。
这项技术还用于下面的情况:一个频繁执行的操作既需要像buffer这样的临时对象,同时还需要避免每次都重分配该临时对象。
与线程相关的值存储在线程对象自身中,线程终止后,这些值会被垃圾回收。
不可变性:
不可变对象永远是线程安全的。
只有满足如下状态,一个对象才是不可变的。
1. 它的状态不能在创建后再被修改。
2. 所有域都是final类型
3. 它被正确创建(创建期没有发生this引用的逸出)
使用volatile发布不可变对象
不论何时,对一组相关数值都应该执行原子操作,并且可以考虑为它们创建不可变的容器类,比如下面的OneValueCache。通过使用不可变对象来持有所有的变量,可以消除在访问和更新这些变量时的竞争条件。若使用可变的容器对象,你就必须使用锁以确保原子性;使用不可变对象,一旦一个线程获得了它的引用,永远不必担心其他线程会修改它的状态。
@Immutable
class OneValueCache {
private final BigInteger lastNumber;
private final BigInteger[] lastFactors;
public OneValueCache(BigInteger i,
BigInteger[] factors) {
lastNumber = i;
lastFactors = Arrays.copyOf(factors,
factors.length);
}
public BigInteger[] getFactors(BigInteger i) {
if (lastNumber == null || !lastNumber.equals(i))
return null;
else
return Arrays.copyOf(lastFactors, lastFactors.length);
} }
重点:当一个线程设置volatile类型的cache域引用到一个新的OneValueCache后,新数据会立即对其他线程可见。
与cache域相关的操作不会相互干扰,因为OneValueCache是不可变的,而且每次只有一条相应的代码路径访问它。不可变的容器对象持有与不变约束相关的多个状态变量,并利用volatile引用确保及时的可见性。
目前为止我们都关注确保对象不会被发布。比如,让对象限制在线程中或者另一个对象的内部。
@ThreadSafe
public class VolatileCachedFactorizer implements Servlet {
private volatile OneValueCache cache =
new OneValueCache(null, null);
public void service(ServletRequest req, ServletResponse resp) {
BigInteger i = extractFromRequest(req);
BigInteger[] factors = cache.getFactors(i);
if (factors == null) {
factors = factor(i);
cache = new OneValueCache(i, factors);
}
encodeIntoResponse(resp, factors);
}
}
安全发布的模式
如果一个对象不是不可变的,它就必须被安全地发布,通常发布线程与消费线程都必须同步化。
为了安全地发布对象,对象的引用以及对象的状态必须同时对其他线程可见。一个正确创建的对象可以通过下列条件安全地发布。
1. 通过静态初始化器初始化对象的引用;
2. 将它的引用存储到volatile域或AtomicReference;
3. 将它的引用存储到正确创建的对象的final域中。
4. 或者将它的引用存储到由锁正确保护的域中。
4条中的:置入Hashtable、synchronizedMap、ConcurrentMap中的主键以及键值,会安全地发布到可以从Map获得它们的任意线程中,无论是直接获得还是通过迭代器或者。
通常,以最简单和最安全的方式发布一个被静态创建的对象,就是使用静态初始化器:
public static Holder holder = new Holder(42)
静态初始化由JVM在类的初始阶段执行,由JVM内在的同步,该机制确保了以这种方式初始化的对象可以被安全地发布。
安全地共享对象
在并发程序中,使用和共享对象的一些最有效的策略如下:
1. 线程限制:一个线程限制的对象,通过限制在线程中,而被线程独占,且只能被占有它的线程修改。
2. 共享只读:一个共享只读对象,在没有额外同步的情况下,可以被多个线程并发地访问,但是任何线程都不能修改它。共享只读对象包括可变对象与搞笑不可变对象。
3. 共享线程安全:一个线程安全的对象在内部进行同步,所以其他线程无须额外同步,久可以通过公共接口随意地访问它。
4. 被守护的:一个被守护的对象只能通过特定的锁来访问。被守护的对象包括那些被线程安全对象封装的对象,和已知被特定的锁保护起来的已发布对象。
分享到:
相关推荐
"大漠多线程模板"是一个专门针对C#开发的多线程处理框架,它为开发者提供了便捷的方式来管理和优化多线程应用。这个框架由知名开发者"大漠"创建,旨在简化复杂的并发编程,提高代码的可读性和可维护性。 多线程允许...
在IT行业中,多线程是一种常见的编程技术,它允许程序同时执行多个独立的任务,从而提高计算机系统的效率和响应性。特别是在自动化工具如“按键精灵”中,多线程的应用能够显著提升其性能和实用性。 标题“多线程_...
标题中的“pb9多线程控件”指的是在PowerBuilder 9.0(PB9)环境中,使用的一种能够实现真正多线程功能的组件或技术。PowerBuilder是一款经典的面向对象的开发工具,主要用于构建数据库应用系统。在PB的早期版本中,...
在编程领域,多线程是实现并发执行任务的重要机制,特别是在现代计算机系统中,多核处理器使得多线程成为提高程序性能的关键手段。C#语言提供了丰富的多线程支持,让我们能够编写出高效的多线程应用程序。在这个"多...
在IT领域,多线程编程是一项关键技能,尤其是在性能优化和并发处理方面。本文将深入探讨多线程编程的基础知识,以帮助初学者快速入门。 首先,我们需要理解什么是多线程。多线程是指在一个进程中同时执行多个独立的...
基于SpringBoot和POI实现单线程和多线程导出Excel.zip基于SpringBoot和POI实现单线程和多线程导出Excel.zip基于SpringBoot和POI实现单线程和多线程导出Excel.zip基于SpringBoot和POI实现单线程和多线程导出Excel.zip...
在编程领域,多线程是实现并发执行任务的重要机制,特别是在易语言中,它能有效提升程序的执行效率。易语言是一种中文编程语言,旨在降低编程门槛,让普通用户也能进行程序开发。本文将深入探讨易语言中的多线程以及...
在.NET框架中,C#语言提供了强大的多线程支持,使得开发者可以充分利用现代多核处理器的优势,实现并行处理和高效能编程。本资源包含六个C#.NET多线程的实例,涵盖了多线程的基本使用到更高级的概念,如线程互斥。...
在IT行业中,多线程是程序设计中的一个重要概念,尤其在Java编程中,它被广泛应用于提高应用程序的并发性能和响应速度。本压缩包“多线程基础与基于多线程的简单聊天室”提供了对多线程技术的实践理解和二次开发的...
在编程领域,尤其是在开发高效、响应迅速的应用程序时,多线程技术扮演着至关重要的角色。Qt5框架提供了一种方便的方式来实现多线程,它允许开发者在不同的线程中执行任务,从而避免主线程(GUI线程)因处理耗时操作...
本文将详细探讨PB(包括PB9、PB12.5以及PB.NET)实现多线程的方法。 一、PB9的多线程实现 在PB9中,虽然官方并未直接支持多线程,但开发者可以通过使用Windows API函数来实现。一种常见的方式是创建一个新的窗口类...
"鱼刺多线程模块"是一个专为提升程序运行效率而设计的开源组件,它主要聚焦于多线程技术的应用。在计算机科学中,多线程是并发执行多个任务或子任务的一种方法,使得程序能够更高效地利用系统资源,特别是在多核...
Qt 多线程及简单实例 demo。 多线程的几大特点: 1.多线程的执行顺序无法保证,与操作系统的调度策略和线程优先级等因素有关。 2.多线程的切换可能发生在任何时刻、任何地点。 3.多线程对代码的敏感度高,因此对...
Linux 下 C 语言多线程编程实例 Linux 下的多线程编程是一种非常重要的技术,在实际应用中有非常广泛的应用范围。多线程编程可以大大提高程序的执行效率和响应速度。但是,多线程编程也存在一些复杂性,例如线程...
单线程和多线程是计算机程序执行时的两种不同模型,它们在处理并发任务、资源管理和性能上有着显著的差异。理解这两种模型是编程尤其是服务器端开发的基础,尤其是在Java、C#等支持多线程的编程语言中。 首先,让...
在Delphi编程中,多线程技术被广泛用于提高应用程序的执行效率,特别是在处理大量数据或执行长时间操作时。DLL(动态链接库)是Windows操作系统中的一个重要组件,它允许代码和资源在多个程序之间共享。当需要在多...
在C#编程中,多线程技术常用于提高应用程序的执行效率,特别是在处理数据库操作时。SQLite是一款轻量级、嵌入式的关系型数据库,它广泛应用于桌面应用、移动设备和Web开发。当多线程环境对SQLite进行读写操作时,...
### 可并行递归算法的递归多线程实现:深入解析 #### 引言:多线程与并行处理的重要性 随着计算任务日益复杂,传统的单线程编程模型已无法满足高效处理大规模数据的需求。多线程编程作为一种提高程序并发性和性能...
"鱼刺多线程注册源码例子"是一个基于"鱼刺多线程稳定框架"的编程实践,旨在展示如何在软件开发中有效地利用多线程技术来提高程序的执行效率和稳定性。在这个例子中,"鱼刺框架"可能是一个专门为多线程编程设计的开源...
多线程是实现复杂任务并发执行的关键技术,能够提高资源利用率,优化系统响应时间。在STM32上实现多线程,通常会借助实时操作系统(RTOS)如RT-Thread。 RT-Thread是一个轻量级、开源的实时操作系统,它为STM32等微...