生产问题: 利用线程Thread预加载数据缓存偶发加载不到
先上代码
public class ThreadTest {
//本地缓存
Map<String, Object> map = new HashMap<String, Object>();
class ThreadA implements Runnable{
@Override
public void run() {
System.out.println("ThreadA");
initCache();
}
}
//加载缓存
void initCache(){
for (int i = 0; i < 5; i++) {
map.put(String.valueOf(i),i);
}
}
void ThreadTestStart(){
for (int i = 0; i < 10; i++) {
Thread threadA = new Thread(new ThreadA());
threadA.setName("threadA"+i);
//threadA.setPriority(10);//设置优先级
threadA.start();
System.out.println(threadA.getName());
}
}
void getCacheByKey(String key){
Object value = map.get(key);
System.out.println("key:"+key+"-value:"+value);
}
public static void main(String[] args) {
try {
ThreadTest threadTest = new ThreadTest();
threadTest.ThreadTestStart();
//Thread.sleep(500);//睡眠500毫秒等待可以拿到数据
threadTest.getCacheByKey("1");
} catch (Exception e) {
e.printStackTrace();
}
}
}
利用线程去加载缓存的时候, 线程start() 不一定立即执行, 要等分配时间片,
线程启动后,在这个时候去获取数据时会拿不到数据
睡眠一下
本人在生产的场景是这样子的(一个运行了十年的老项目)
一个bean实现了 BeanPostProcessor 接口,重写 postProcessAfterInitialization() 方法来加载缓存 initCache , 这个加载方法是新建了一个线程Thread 并启动start() , 这个本地缓存在Controller的全局变量中获取使用, 导致启动项目时会偶发报错 ( 取决于加载缓存的线程能不能拿到时间片去执行run()方法从而加载缓存 ) , 可能是这个线程的优先级不高, 然后就设置了优先级为最大 setPriority(10) , 默认的优先级是5