标签 ‘ collections ’
Java 7中的TransferQueue
原文链接,译文链接,作者:Alex Miller,译者:Greenster,校对:梁海舰
Java7中加入了JSR 166y规范对集合类和并发类库的改进。其中的一项是增加了接口TransferQueue
和其实现类LinkedTransferQueue
。
TransferQueue继承了BlockingQueue(
BlockingQueue又
继承了Queue
)并扩展了一些新方法。BlockingQueue(和Queue)是Java 5中加入的接口,它是指这样的一个队列:当生产者向队列添加元素但队列已满时,生产者会被阻塞;当消费者从队列移除元素但队列为空时,消费者会被阻塞。
阅读全文
并发集合(七)创建并发随机数
声明:本文是《 Java 7 Concurrency Cookbook 》的第六章,作者: Javier Fernández González 译者:许巧辉 校对:方腾飞
创建并发随机数
Java并发API提供指定的类在并发应用程序中生成伪随机。它是ThreadLocalRandom类,这是Java 7版本中的新类。它使用线程局部变量。每个线程希望以不同的生成器生成随机数,但它们是来自相同类的管理,这对程序员是透明的。在这种机制下,你将获得比使用共享的Random对象为所有线程生成随机数更好的性能。
在这个指南中,你将学习如何在并发应用程序中使用ThreadLocalRandom生成随机数。
并发集合(六)使用线程安全的NavigableMap
声明:本文是《 Java 7 Concurrency Cookbook 》的第六章,作者: Javier Fernández González 译者:许巧辉 校对:方腾飞
使用线程安全的NavigableMap
Java API 提供的有趣的数据结构,并且你可以在并发应用程序中使用,它就是ConcurrentNavigableMap接口的定义。实现ConcurrentNavigableMap接口的类存储以下两部分元素:
- 唯一标识元素的key
- 定义元素的剩余数据
每部分在不同的类中实现。
Java API 也提供了这个接口的实现类,这个类是ConcurrentSkipListMap,它实现了非阻塞列表且拥有ConcurrentNavigableMap的行为。在内部实现中,它使用Skip List来存储数据。Skip List是基于并行列表的数据结构,它允许我们获取类似二叉树的效率。使用它,你可以得到一个排序的数据结构,这比排序数列使用更短的访问时间来插入、搜索和删除元素。
注意:在1990年,由William Pugh引入Skip List。
当你往map中插入数据时,它使用key来排序它们,所以,所有元素将是有序的。除了返回具体的元素,这个类也提供了获取map的子map的方法。 阅读全文
并发集合(五)使用线程安全的、带有延迟元素的列表
声明:本文是《 Java 7 Concurrency Cookbook 》的第六章,作者: Javier Fernández González 译者:许巧辉 校对:方腾飞
使用线程安全的、带有延迟元素的列表
DelayedQueue类是Java API提供的一种有趣的数据结构,并且你可以用在并发应用程序中。在这个类中,你可以存储带有激活日期的元素。方法返回或抽取队列的元素将忽略未到期的数据元素。它们对这些方法来说是看不见的。
为了获取这种行为,你想要存储到DelayedQueue类中的元素必须实现Delayed接口。这个接口允许你处理延迟对象,所以你将实现存储在DelayedQueue对象的激活日期,这个激活时期将作为对象的剩余时间,直到激活日期到来。这个接口强制实现以下两种方法:
- compareTo(Delayed o):Delayed接口继承Comparable接口。如果执行这个方法的对象的延期小于作为参数传入的对象时,该方法返回一个小于0的值。如果执行这个方法的对象的延期大于作为参数传入的对象时,该方法返回一个大于0的值。如果这两个对象有相同的延期,该方法返回0。
- getDelay(TimeUnit unit):该方法返回与此对象相关的剩余延迟时间,以给定的时间单位表示。TimeUnit类是一个枚举类,有以下常量:DAYS、HOURS、 MICROSECONDS、MILLISECONDS、 MINUTES、 NANOSECONDS 和 SECONDS。
并发集合(四)用优先级对使用阻塞线程安全的列表排序
声明:本文是《 Java 7 Concurrency Cookbook 》的第六章,作者: Javier Fernández González 译者:许巧辉 校对:方腾飞
用优先级对使用阻塞线程安全的列表排序
一个典型的需求是,当你需要使用一个有序列表的数据结构时,Java提供的PriorityBlockingQueue类就拥有这种功能。
你想要添加到PriorityBlockingQueue中的所有元素必须实现Comparable接口。这个接口有一个compareTo()方法,它接收同样类型的对象,你有两个比较的对象:一个是执行这个方法的对象,另一个是作为参数接收的对象。如果本地对象小于参数,则该方法返回小于0的数值。如果本地对象大于参数,则该方法返回大于0的数值。如果本地对象等于参数,则该方法返回等于0的数值。 阅读全文
并发集合(二)使用非阻塞线程安全的列表
声明:本文是《 Java 7 Concurrency Cookbook 》的第六章,作者: Javier Fernández González 译者:许巧辉
使用非阻塞线程安全的列表
列表(list)是最基本的集合。一个列表有不确定的元素数量,并且你可以添加、读取和删除任意位置上的元素。并发列表允许不同的线程在同一时刻对列表的元素进行添加或删除,而不会产生任何数据不一致(问题)。
在这个指南中,你将学习如何在你的并发应用程序中使用非阻塞列表。非阻塞列表提供这些操作:如果操作不能立即完成(比如,你想要获取列表的元素而列表却是空的),它将根据这个操作抛出异常或返回null值。Java 7引进实现了非阻塞并发列表的ConcurrentLinkedDeque类。
我们将使用以下两种不同任务来实现一个例子:
- 大量添加数据到列表
- 在同个列表中,大量删除数据
并发集合(一)引言
声明:本文是《 Java 7 Concurrency Cookbook 》的第六章,作者: Javier Fernández González 译者:许巧辉 校对:方腾飞
在本章中,我们将包含:
- 使用非阻塞线程安全的列表
- 使用阻塞线程安全的列表
- 用优先级对使用阻塞线程安全的列表排序
- 使用线程安全的、带有延迟元素的列表
- 使用线程安全的NavigableMap
- 创建并发随机数
- 使用原子变量
- 使用原子数组
引言
在编程中,数据结构是一种基本的元素。几乎每个程序都使用一个或多个数据结构类型来存储和管理它们的数据。Java API提供了Java集合框架(Java Collections framework),它包括可以用来实现许多不同的数据结构的接口、类和算法,你可以在程序中使用它们。
当你需要在并发程序中使用数据集合时,你必须十分小心的选择实现。大多数集合数并不适合用在并发应用程序中,因为它们没有控制并发访问数据。如果一些并发任务共享一个数据结构,而这个数据结构并不适合用在并发任务中,你将会有数据不一致的错误,这将影响到程序的正确运行。ArrayList类就是这种数据结构的一个例子。
阅读全文