12345678910111213141516171819202122232425262728293031323334353637383940 |
- package com.yihu.ehr.service.thread;
- import com.yihu.ehr.common.config.ThreadConfig;
- import com.yihu.ehr.service.crawler.CrawlerManager;
- import com.yihu.ehr.service.standard.StandardManager;
- import com.yihu.ehr.util.log.LogUtil;
- public class CrawlerSupplyThread implements Runnable {
- @Override
- public void run() {
- while (ThreadManage.crawlerSupplyIsRunning) {
- try {
- LogUtil.info("补采线程开始");
- CrawlerManager.getInstance().dataCrawlerSupply();
- LogUtil.info("补采线程结束");
- sleep();
- } catch (InterruptedException e) {
- LogUtil.error("休眠中断!");
- LogUtil.error(e);
- continue;
- } catch (Exception e) {
- LogUtil.error("补采线程失败,将重启启动线程!");
- LogUtil.error(e);
- try {
- sleep();
- } catch (Exception e1) {
- continue;
- }
- continue;
- }
- }
- }
- private void sleep() throws Exception {
- LogUtil.info("开始睡眠,睡眠时间:" + 1000 * ThreadConfig.CRAWLER_SUPPLY_THREAD_SLEEP_TIME);
- Thread.sleep(1000 * ThreadConfig.CRAWLER_SUPPLY_THREAD_SLEEP_TIME);
- }
- }
|