CrawlerSupplyThread.java 1.3 KB

12345678910111213141516171819202122232425262728293031323334353637383940
  1. package com.yihu.ehr.service.thread;
  2. import com.yihu.ehr.common.config.ThreadConfig;
  3. import com.yihu.ehr.service.crawler.CrawlerManager;
  4. import com.yihu.ehr.service.standard.StandardManager;
  5. import com.yihu.ehr.util.log.LogUtil;
  6. public class CrawlerSupplyThread implements Runnable {
  7. @Override
  8. public void run() {
  9. while (ThreadManage.crawlerSupplyIsRunning) {
  10. try {
  11. LogUtil.info("补采线程开始");
  12. CrawlerManager.getInstance().dataCrawlerSupply();
  13. LogUtil.info("补采线程结束");
  14. sleep();
  15. } catch (InterruptedException e) {
  16. LogUtil.error("休眠中断!");
  17. LogUtil.error(e);
  18. continue;
  19. } catch (Exception e) {
  20. LogUtil.error("补采线程失败,将重启启动线程!");
  21. LogUtil.error(e);
  22. try {
  23. sleep();
  24. } catch (Exception e1) {
  25. continue;
  26. }
  27. continue;
  28. }
  29. }
  30. }
  31. private void sleep() throws Exception {
  32. LogUtil.info("开始睡眠,睡眠时间:" + 1000 * ThreadConfig.CRAWLER_SUPPLY_THREAD_SLEEP_TIME);
  33. Thread.sleep(1000 * ThreadConfig.CRAWLER_SUPPLY_THREAD_SLEEP_TIME);
  34. }
  35. }