当前位置: 首页 > 后端技术 > Java

线程验证中断刷新

时间:2023-04-01 16:01:23 Java

检查当前线程是否中断或停止刷新refreshTad=newThread(()->{logger.info("RMQ对应接口消费状态刷新...");while(!Thread.currentThread().isInterrupted()){try{try{Thread.sleep(1000*QContext.RMQ_CONSUMER_REFRESH_INTERVAL);}catch(InterruptedExceptionex){}if(logger.isDebugEnabled()){logger.debug("执行RMQ对应接口消费者状态刷新.....”);}EsbCacheManagercacheManager=BeanFactoryHelper.getBean("esbCacheManager",EsbCacheManager.class);QContext.rmqConsumerActionIds.forEach((k,v)->cacheManager.recordActionIdForConsumerOk(v,QContext.RMQ_CONSUMER_TTL));异常e){logger.error("RMQ对应接口消费状态刷新错误",e);尝试{Thread.sleep(10000);}catch(InterruptedExceptionex){}}}});检查线程是否中断Thread.currentThread()返回当前线程对象,isInterrupted()检查当前对象是否中断,内容不断刷新时不中断循环