ScheduledExecutorService service = Executors.newScheduledThreadPool(1);
service.scheduleAtFixedRate(new SwitchTask(), 1, 1, TimeUnit.MINUTES);
/**
* 定时更新缓存中的key
* @author xuchuanbao1
*
*/
private class SwitchTask implements Runnable{
@Override
public void run() {
for( String key : switchList) {
try {
// logger.info("switch begin=== "+key);
String value = r2mClusterClient.get(key);
if (StringUtils.isNotBlank(value)) {
SwitchCacheMapUtils.switchMap.put(key, value);
}
logger.info("switch end=== "+key+" value:"+value);
} catch (Exception e) {
logger.error("excute load cacheR2m_swtich ", e);
}
}
}
}