集合类的发展历程
? 早期集合类Vector、Hashtable:线程安全的。是怎么保证线程安排的,使用synchronized修饰方法 ? 为了提高性能,使用ArrayList、HashMap替换,线程不安全,但是性能好。使用ArrayList、HashMap,需要线程安全怎么办呢?使用Collections.synchronizedList(list)、Collections.synchronizedMap(m)解决,底层使用synchronized代码块锁。 虽然也是锁住了所有的代码,但是锁在方法里边,并所在方法外边性能可以理解为稍有提高吧。毕竟进方法本身就要分配资源的 ? 在大量并发情况下如何提高集合的效率和安全呢? 提供了新的线程同步集合类,位于java.util.concurrent包下,使用Lock锁或者volatile+CAS的无锁化。 ConcurrentHashMap CopyOnWriteArrayList CopyOnWriteArraySet
新一代并发集合类
ConcurrentHashMap
ConcurrentHashMap是并发效率更高的Map,用来替换其他线程安全的Map容器,比如Hashtable和Collections.synchronizedMap。实际上,并发执行时,线程安全的容器只能保证自身的数据不被破坏,但无法保证业务的行为是否正确。错误的理解这里的线程安全,不恰当的使用ConcurrentHashMap,往往会导致出现问题
public static void main(String[] args) {
final Map<String, AtomicInteger> count = new ConcurrentHashMap<>();
final CountDownLatch endLatch = new CountDownLatch(2);
Runnable task = new Runnable() {
@Override
public void run() {
AtomicInteger oldValue;
for (int i = 0; i < 5; i++) {
oldValue = count.get("a");
if (null == oldValue) {
AtomicInteger zeroValue = new AtomicInteger(0);
oldValue = count.putIfAbsent("a", zeroValue);
if (null == oldValue) {
oldValue = zeroValue;
}
}
oldValue.incrementAndGet();
}
endLatch.countDown();
}
};
new Thread(task).start();
new Thread(task).start();
try {
endLatch.await();
System.out.println(count);
} catch (Exception e) {
e.printStackTrace();
}
}
为什么ConcurrentHashMap不允许插入null值? https://juejin.cn/post/7057696800739688479 HashMap与ConcurrentHashMap面试要点https://juejin.cn/post/7097147987058491423
CopyOnWriteArrayList
先简单说一说Java中的CopyOnWriteArrayListhttps://juejin.cn/post/6844903576339218440
public class IteratorTest {
private static CopyOnWriteArrayList<String> list = new CopyOnWriteArrayList<>();
public static void main(String[] args) {
list.add("1");
list.add("2");
list.add("3");
Iterator<String> iter = list.iterator();
ExecutorService service = Executors.newFixedThreadPool(10);
for (int i = 0; i < 10; i++) {
service.execute(new Runnable() {
@Override
public void run() {
while (iter.hasNext()) {
System.err.println(iter.next());
}
}
});
}
for (int i = 0; i < 10; i++) {
service.execute(new Runnable() {
@Override
public void run() {
list.add("121");
}
});
}
System.err.println(Arrays.toString(list.toArray()));
}
}
CopyOnWriteArrayList 你了解多少?https://segmentfault.com/a/1190000021789020
CopyOnWriteArraySet
面试官:Java 有线程安全的 set 吗?我竟然答不上来 https://segmentfault.com/a/1190000040871613
|