package com.nq.utils.task.news; import com.nq.service.ISiteArticleService; import com.nq.service.ISiteNewsService; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; //import org.springframework.scheduling.annotation.Scheduled; @Component public class NewsTask { private static final Logger log = LoggerFactory.getLogger(NewsTask.class); @Autowired ISiteNewsService iSiteNewsService; @Autowired ISiteArticleService iSiteArticleService; boolean NewsInfoTask = true; private final Lock NewsInfoTaskLock = new ReentrantLock(); /* * 新聞資訊抓取 * */ @Scheduled(cron = "0/1 * * * * ?") public void NewsInfoTask() { if (NewsInfoTask) NewsInfoTask = false; else return; if (NewsInfoTaskLock.tryLock()) { try { System.out.println("新闻定时任务---->开始"); this.iSiteNewsService.grabNews(); } catch (Exception e) { e.printStackTrace(); } finally { NewsInfoTaskLock.unlock(); NewsInfoTask = true; } System.out.println("新闻定时任务---->结束"); } } /* * 新聞公告抓取 * */ // @Scheduled(cron = "0 0/30 9-20 * * ?") // public void ArtInfoTask() { // this.iSiteArticleService.grabArticle(); // } }