并发编程陷阱系列 (一)同步不完全

同步块未覆盖到所有场景。

 

import java.util.HashMap;
import java.util.Map;

public class CacheManage {
	private Map<String, String> cache = new HashMap<String, String>();

	public static int THREADS_COUNT = 2;

	public void fresh() {
		synchronized (cache) {
			cache.clear();
		}
	}

	public void put(String key, String value) {
		synchronized (cache) {
			cache.put(key, value);
			System.out.println(Thread.currentThread().getName()
					+ "  cache.put--------" + value);
		}
	}

	public String get(String key) {
		System.out.println(Thread.currentThread().getName()
				+ "  cache.get-----" + cache.get(key));
		return cache.get(key);
	}

	public static void main(String[] args) {
		final CacheManage cacheManage = new CacheManage();
		Thread[] threads = new Thread[THREADS_COUNT];
		for (int i = 0; i < THREADS_COUNT; i++) {
			threads[i] = new Thread(new Runnable() {
				public void run() {
					for (int i = 0; i < 10; i++) {
						cacheManage.put("a", i + 1 + "");
						try {
							Thread.sleep(1000);
						} catch (InterruptedException e) {
							// TODO Auto-generated catch block
							e.printStackTrace();
						}
						cacheManage.get("a");
					}
				}
			});
			threads[i].start();
		}
	}
}

 上面的缓存管理类，启动2个线程对其进行访问，每个线程做的事情都一样，先put后get，打印的结果为：

 

Thread-0  cache.put--------1

Thread-1  cache.put--------1

Thread-0  cache.get-----1

Thread-0  cache.put--------2

Thread-1  cache.get-----1

...

分析：Thread0在写数据（将缓存修改成2）的同时，thread1将数据取出来了，thread1读取了旧的缓存。

总结：读时不能写 写时不能读  可以并发读  不能并发写

 

 

 

 

评论

5 楼 不懂甜言蜜语 2014-08-03  

感觉for循环里的需求只是线程范围内数据共享，用ThreadLocal

4 楼 不懂甜言蜜语 2014-08-03  

做到这个要求“总结：读时不能写 写时不能读  可以并发读  不能并发写”

3 楼 不懂甜言蜜语 2014-08-03  

怎么解决？？？能想到的只有读写锁了，可以吗？

2 楼 Chunxian 2014-07-17  

那个在for循环里面给cacheManage上锁，这样是不是就好了？（初学，我试了一下是可以的，个人觉得，操作什么就给什么上锁就行了）

1 楼 liyanjing1987 2014-05-06  

不是很明白，这个缓存里面读出来的？哪里的缓存？  Map本就放在内存里面，从哪来的缓存？