From e88a8fd3b5e290b573b15a7f6611c586d2367823 Mon Sep 17 00:00:00 2001 From: wangyuan Date: Mon, 15 Jul 2019 16:50:54 +0800 Subject: [PATCH] thread --- .../src/main/java/com/ljsd/jieling/thread/ThreadManager.java | 4 ++-- .../main/java/com/ljsd/jieling/thread/task/MinuteTask.java | 5 ++++- 2 files changed, 6 insertions(+), 3 deletions(-) diff --git a/serverlogic/src/main/java/com/ljsd/jieling/thread/ThreadManager.java b/serverlogic/src/main/java/com/ljsd/jieling/thread/ThreadManager.java index b01c3ddc9..4c5707fb3 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/thread/ThreadManager.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/thread/ThreadManager.java @@ -84,8 +84,6 @@ public class ThreadManager { int delayForMinute = 60 - (now%60); LOGGER.info("delayForMinute---->>>>{}" ,delayForMinute); scheduledExecutor.scheduleAtFixedRate(platConfigureTask, 10, SLEEP_INTEVAL_TIME, TimeUnit.SECONDS); - scheduledExecutor.scheduleAtFixedRate(dataReportTask, 10, SLEEP_INTEVAL_TIME, TimeUnit.SECONDS); - scheduledExecutor.scheduleAtFixedRate(mongoDataHandlerTask, 10, SLEEP_INTEVAL_TIME, TimeUnit.SECONDS); scheduledExecutor.scheduleAtFixedRate(new MinuteTask(), delayForMinute, 60, TimeUnit.SECONDS); scheduledExecutor.scheduleAtFixedRate(new Thread(){ public void run () { @@ -98,6 +96,8 @@ public class ThreadManager { } }, delayForMinute, 10, TimeUnit.SECONDS); scheduledExecutor.execute(new RetrySendIndicationThread("retry_send")); + scheduledExecutor.execute(dataReportTask); + scheduledExecutor.execute(mongoDataHandlerTask); } public static void reStart(){ LOGGER.info("重启线程池!!"); diff --git a/serverlogic/src/main/java/com/ljsd/jieling/thread/task/MinuteTask.java b/serverlogic/src/main/java/com/ljsd/jieling/thread/task/MinuteTask.java index 012d16e00..697859348 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/thread/task/MinuteTask.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/thread/task/MinuteTask.java @@ -97,10 +97,13 @@ public class MinuteTask extends Thread { Calendar calendar = Calendar.getInstance(); int hour = calendar.get(Calendar.HOUR_OF_DAY); int minute = calendar.get(Calendar.MINUTE); - if(hour == 5 && minute ==0){ + int w = calendar.get(Calendar.DAY_OF_WEEK) - 1; + + if(w == 1 &&hour == 5 && minute ==0){ LOGGER.info("everyMondyFiveClockTask start ..."); CombatLogic.getInstance().sendReward(); LOGGER.info("everyMondyFiveClockTask end ..."); } } + }