Java 并发编程(三)为线程安全类中加入新的原子操作

Java 类库中包括很多实用的”基础模块“类。通常,我们应该优先选择重用这些现有的类而不是创建新的类。:重用能减少开发工作量、开发风险(由于现有类都已经通过測试)以及维护成本。有时候,某个线程安全类能支持我们须要的全部操作,但很多其它的时候,现有的类仅仅能支持大部分的操作,此时就须要在不破坏线程安全的情况下加入一个新的操作。

如果我们须要一个线程安全的链表,他须要提供一个原子的”若没有则加入(Put-If-Absent)“的操作。同步的 List 类已经实现了大部分的功能,我们能够依据它提供的 contains 方法和 add 方法构造一个实现。

能够有四种方法来实现这个原子操作。

第一种方法,也是最安全的方法,便是改动原始类。

但这一般是无法做到的,由于你可能无法訪问或改动类的源码。要想改动原始的类,就须要深刻理解代码中的同步策略,这样添加的功能才干与原有的设计保持一致。假设直接将新方法加入到类中,那么意味着实现同步策略的全部代码仍然处于一个源码文件里,从而更easy理解与维护。

另外一种方法,能够扩展(继承)这个类—-假如原始类在设计的时候时考虑到了它的可扩展性。

比如,我们能够设计一个 BetterVector 对 Vector 进行扩展,并加入了一个新方法 putIfAbsent。

public class BetterVector<E> extends Vector<E>{
	public synchronized boolean putIfAbsent(E x){
		boolean absent = !contains(x);
		if(absent)add(x);
		return absent;
	}
}

扩展 Vector 非常easy,但并不是全部的类都像 Vector 那样将状态向子类公开,因此也就不适合採用这样的方法。

”扩展“方法比較脆弱,主要原因是 同步策略的实现被分离到了多个源码文件里,假设底层类改变了同步策略,更改了不同的锁来保护状态,那么子类便会被破坏。

第三种方法,使用辅助类,实现client加锁机制。

对于某些类,比方 Collections.synchronizedList 封装的 ArrayList , 前两种方法都行不通,由于客户代码不知道在同步封装器工厂方法中返回的 List 对象的类型。这时候採用client加锁的方式,将扩展代码放到一个”辅助类“中。

于是我们非常自然的就写出 ListHelper 辅助类。

public class ListHelper<E>{
	public List<E> list = Collections.synchronizedList(new ArrayList<E>());
	public synchronized boolean putIfAbsent(E x){
		boolean absent = !list.contains(x);
		if(absent)
			list.add(x);
		return absent;
	}
}

咋一看没问题,但是非常遗憾,这样的方式是错误的。

尽管 putIfAbsent 已经声明为 synchronized ,可是它却是在 ListHelper 上加锁,而 List 却是用自己或内部对象的锁。 ListHelper 仅仅是带来了同步的假象,

在 Vector 和同步封装器类的文档中指出,他们是通过 Vector 或封装容器内部锁来支持client加锁。以下我们给出正确的client加锁。

public class ListHelper<E>{
	public List<E> list = Collections.synchronizedList(new ArrayList<E>());
	public boolean putIfAbsent(E x){
		synchronized (list){
			boolean absent = !list.contains(x);
			if(absent)
				list.add(x);
		return absent;}
	}
}

通过加入一个原子操作来扩展类是脆弱的,由于它将类的加锁代码分布到多个类中。然而,client加锁却更加脆弱,由于它将类的加锁代码放到与其全然无关的其它类中。

第四种方法,使用组合(Composition)的方式。

public  class ImprovedList<T> implements List<T> {
	public final List<T> list;

	public ImprovedList(List<T> list) {
		this.list = list;
	}

	public synchronized boolean putIfAbsent(T x) {
		boolean absent = !list.contains(x);
		if (absent)
			list.add(x);
		return absent;
	}

	//...依照相似的方式托付List的其它方法
}

ImprovedList 通过自身的内置锁添加了一层额外的加锁。它并不关心底层的 List 是否是线程安全的,即使 List 不是线程安全的或者改动了它的枷锁方式,Improved 也会提供一致的加锁机制来实现线程安全性。尽管额外的同步层可能导致轻微的性能损失,但与模拟还有一个对象的加锁策略相比,ImprovedList 更为健壮。其实,我们使用了 Java 监视器模式来封装现有 List ,而且仅仅要在类中拥有指向底层 List 的为意外不引用,就能确保线程安全性。

时间: 2024-11-08 19:25:21

Java 并发编程(三)为线程安全类中加入新的原子操作的相关文章

Java 并发编程(三)为现有的线程安全类中添加新的原子操作

Java 类库中包含许多有用的"基础模块"类.通常,我们应该优先选择重用这些现有的类而不是创建新的类.:重用能降低开发工作量.开发风险(因为现有类都已经通过测试)以及维护成本.有时候,某个线程安全类能支持我们需要的所有操作,但更多的时候,现有的类只能支持大部分的操作,此时就需要在不破坏线程安全的情况下添加一个新的操作. 假设我们需要一个线程安全的链表,他需要提供一个原子的"若没有则添加(Put-If-Absent)"的操作.同步的 List 类已经实现了大部分的功能

Java并发编程 - 关于扩展线程安全类的一些思考

"重用"大法好,我们早已习惯重用已设计好的类而不是自己造轮子玩. 重用可以节省我们进行开发和测试(测试比我们自己测严谨地多)的时间和其他各种成本. 但是,对一个线程安全类进行扩展的时候就需要思考一些问题. 比如我们熟知的线程安全类Vector,该类中对所有的公有方法提供了synchronized修饰以保证访问互斥与可见性. 但Vector毕竟是一个公有的结构,他对客户代码的不变性约束一无所知. 比如客户代码中对某个Vector对象连续调用了两次方法,虽然每次都是线程安全的,但这种复合操

JAVA并发-为现有的线程安全类添加原子方法

JAVA中有许多线程安全的基础模块类,一般情况下,这些基础模块类能满足我们需要的所有操作,但更多时候,他们并不能满足我们所有的需要.此时,我们需要想办法在不破坏已有的线程安全类的基础上添加一个新的原子操作.有如下4中方案: 1 修改类的源码,以添加新的原子操作 2 继承该线程安全类,并添加原子操作 3 使用客户端加锁方式 4 使用组合方式(推荐) 一般来讲,修改源码的方式不太可行,这样会破坏原有类的封装性而且有些时候,源码不可获得.我们从第二种方式开始举例: 假设现在对于类Vector,我们知道

Java并发编程系列(一)-线程的基本使用

最近在学习java并发编程基础.一切从简,以能理解概念为主. 并发编程肯定绕不过线程.这是最基础的. 那么就从在java中,如何使用线程开始. 继承Thread类 继承Thread类,重写run方法,new出对象,调用start方法. 在新启的线程里运行的就是重写的run方法. 1 /** 2 * 集成Thread类 实现run() 3 */ 4 public class C1 extends Thread { 5 6 @Override 7 public void run() { 8 try

Java并发编程三个性质:原子性、可见性、有序性

并发编程 并发程序要正确地执行,必须要保证其具备原子性.可见性以及有序性:只要有一个没有被保证,就有可能会导致程序运行不正确 线程不安全在编译.测试甚至上线使用时,并不一定能发现,因为受到当时的CPU调度顺序,线程个数.指令重排的影响,偶然触发 线程安全的定义 比如说一个类,不论通过怎样的调度执行顺序,并且调用处不用对其进行同步操作,其都能表现出正确的行为,则这个类就是线程安全的 并发编程三个概念 原子性: 一个操作或多个操作要么全部执行且执行过程不被中断,要么不执行 可见性: 多个线程修改同一

【java并发编程实战】-----线程基本概念

学习Java并发已经有一个多月了,感觉有些东西学习一会儿了就会忘记,做了一些笔记但是不系统,对于Java并发这么大的"系统",需要自己好好总结.整理才能征服它.希望同仁们一起来学习Java并发编程,共同进步,互相指导. 在学习Java并发之前我们需要先理解一些基本的概念:共享.可变.线程安全性.线程同步.原子性.可见性.有序性. 共享和可变 要编写线程安全的代码,其核心在于对共享的和可变的状态进行访问. "共享"就意味着变量可以被多个线程同时访问.我们知道系统中的资

Java并发编程(01):线程的创建方式,状态周期管理

本文源码:GitHub·点这里 || GitEE·点这里 一.并发编程简介 1.基础概念 程序 与计算机系统操作有关的计算机程序.规程.规则,以及可能有的文件.文档及数据. 进程 进程是计算机中的程序,关于某数据集合上的一次运行活动,是系统进行资源分配和调度的基本单位,是操作系统结构的基础.在早期面向进程设计的计算机结构中,进程是程序的基本执行实体:在面向线程设计的计算机结构中,进程是线程的容器.程序是指令.数据及其组织形式的描述,进程是程序的实体. 线程 线程是操作系统能够进行运算调度的最小单

Java并发编程(02):线程核心机制,基础概念扩展

本文源码:GitHub·点这里 || GitEE·点这里 一.线程基本机制 1.概念描述 并发编程的特点是:可以将程序划分为多个分离且独立运行的任务,通过线程来驱动这些独立的任务执行,从而提升整体的效率.下面提供一个基础的演示案例. 2.应用案例 场景:假设有一个容器集合,需要拿出容器中的每个元素,进行加工处理,一般情况下直接遍历就好,如果数据偏大,可以根据线程数量对集合切割,每个线程处理一部分数据,这样处理时间就会减少很多. public class ExtendThread01 { publ

Java并发编程学习:线程安全与锁优化

本文参考<深入理解java虚拟机第二版> 一.什么是线程安全? 这里我借<Java Concurrency In Practice>里面的话:当多个线程访问一个对象,如果不考虑这些线程在运行时环境下的调度和交替执行,也不需要额外的同步,或者调用方进行任何其他的协调操作,调用这个对象的行为都可以获得正确的结果,那么这个对象是线程安全的. 我的理解:多线程访问一个对象,任何情况下,都能保持正确行为,就是对象就是安全的. 我们可以将Java语言中各种操作共享的数据分为以下5类:不可变.