Commit 3c11823a authored by 赵啸非's avatar 赵啸非

修改获取轮训redis

parent 0cae78b2
...@@ -36,7 +36,7 @@ public class AttendSummaryService implements IApplicationStartedService { ...@@ -36,7 +36,7 @@ public class AttendSummaryService implements IApplicationStartedService {
Thread sendThread = new Thread(new Runnable() { Thread sendThread = new Thread(new Runnable() {
@Override @Override
public void run() { public void run() {
int waitTime = 100; int waitTime = 1000;
while (!stopped) { while (!stopped) {
try { try {
AttendanceSummaryQuery query = cacheService.brpop(KEY_ATTENDANCE_STAT_CACHE, 60,AttendanceSummaryQuery.class); AttendanceSummaryQuery query = cacheService.brpop(KEY_ATTENDANCE_STAT_CACHE, 60,AttendanceSummaryQuery.class);
...@@ -61,7 +61,7 @@ public class AttendSummaryService implements IApplicationStartedService { ...@@ -61,7 +61,7 @@ public class AttendSummaryService implements IApplicationStartedService {
} }
} catch (Exception e) { } catch (Exception e) {
log.error("异常", e); // log.error("异常", e);
try { try {
Thread.sleep(waitTime); Thread.sleep(waitTime);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment