type
status
date
slug
summary
tags
category
icon
password
Property
前面已经通过
ReentrantLock
和Condition
实现了一个BlockingQueue
:BlockingQueue
的意思就是说,当一个线程调用这个TaskQueue
的getTask()
方法时,该方法内部可能会让线程变成等待状态,直到队列条件满足不为空,线程被唤醒后,getTask()
方法才会返回。因为
BlockingQueue
非常有用,所以我们不必自己编写,可以直接使用Java标准库的java.util.concurrent
包提供的线程安全的集合:ArrayBlockingQueue
。除了
BlockingQueue
外,针对List
、Map
、Set
、Deque
等,java.util.concurrent
包也提供了对应的并发集合类。归纳一下:使用这些并发集合与使用非线程安全的集合类完全相同。我们以
ConcurrentHashMap
为例:因为所有的同步和加锁的逻辑都在集合内部实现,对外部调用者来说,只需要正常按接口引用,其他代码和原来的非线程安全代码完全一样。即当我们需要多线程访问时,把:
改为:
就可以了。
java.util.Collections
工具类还提供了一个旧的线程安全集合转换器,可以这么用:但是它实际上是用一个包装类包装了非线程安全的
Map
,然后对所有读写方法都用synchronized
加锁,这样获得的线程安全集合的性能比java.util.concurrent
集合要低很多,所以不推荐使用。小结
使用
java.util.concurrent
包提供的线程安全的并发集合可以大大简化多线程编程:多线程同时读写并发集合是安全的;
尽量使用Java标准库提供的并发集合,避免自己编写同步代码。