生产问题: 利用线程Thread预加载数据缓存偶发加载不到
先上代码
public class ThreadTest {//本地缓存Map<String, Object> map = new HashMap<String, Object>();class ThreadA implements Runnable{@Overridepublic 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