datasync / yoho-datasync-fullsync · Commits

Go to a project

Authored by 张帅
Commit 4e0f5d42d12ff5a7192208a259d3cae2f8b5fe3b 1 parent ce5b6af0

fix

Inline Side-by-side
Showing 1 changed file with 1 additions and 1 deletions
@@ -78,7 +78,7 @@ public class GrassArticleSyncServiceImpl implements IGrassArticleSyncService { @@ -78,7 +78,7 @@ public class GrassArticleSyncServiceImpl implements IGrassArticleSyncService {
78 @Override 78 @Override
79 public String syncArticle(Long startTime, Long endTime) { 79 public String syncArticle(Long startTime, Long endTime) {
80 logger.info("syncArticle begin, startTime is {}, endTime is {}", startTime, endTime); 80 logger.info("syncArticle begin, startTime is {}, endTime is {}", startTime, endTime);
81 - ExecutorService es = Executors.newSingleThreadExecutor(); 81 + ExecutorService es = Executors.newFixedThreadPool(2);
82 int pageSize = 100; 82 int pageSize = 100;
83 int total = grassArticleRepository.countByCreateTimeAfterAndCreateTimeBeforeAndArticleTypeInAndAuthStatusIn(startTime, endTime,needSyncArticleType,needSyncArticleStatus); 83 int total = grassArticleRepository.countByCreateTimeAfterAndCreateTimeBeforeAndArticleTypeInAndAuthStatusIn(startTime, endTime,needSyncArticleType,needSyncArticleStatus);
84 logger.info("syncArticle get grassArticle count is {}", total); 84 logger.info("syncArticle get grassArticle count is {}", total);