Commit ae0a5009 by zhiwei

修改定时器启动方式

parent 811c679b
......@@ -30,28 +30,28 @@ public class HotSearchRun {
ZhiWeiTools.sleep(10000);
new CacheListener().startListen();
ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(6);
scheduledThreadPool.scheduleAtFixedRate(new WeiboHotSearchRun(), 0, 1, TimeUnit.MINUTES);
scheduledThreadPool.scheduleAtFixedRate(new BaiduHotSearchRun(), 0, 5, TimeUnit.MINUTES);
scheduledThreadPool.scheduleAtFixedRate(new SougoHotSearchRun(), 0, 5, TimeUnit.MINUTES);
scheduledThreadPool.scheduleAtFixedRate(new DouyinHotSearchRun(), 0, 10, TimeUnit.MINUTES);
scheduledThreadPool.scheduleAtFixedRate(new ZhihuHotSearchRun(), 0, 10, TimeUnit.MINUTES);
scheduledThreadPool.scheduleAtFixedRate(new WeiboTopicRun(), 0, 1, TimeUnit.DAYS);
// ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(6);
//
// scheduledThreadPool.scheduleAtFixedRate(new WeiboHotSearchRun(), 0, 1, TimeUnit.MINUTES);
//
// scheduledThreadPool.scheduleAtFixedRate(new BaiduHotSearchRun(), 0, 5, TimeUnit.MINUTES);
//
// scheduledThreadPool.scheduleAtFixedRate(new SougoHotSearchRun(), 0, 5, TimeUnit.MINUTES);
//
// scheduledThreadPool.scheduleAtFixedRate(new DouyinHotSearchRun(), 0, 10, TimeUnit.MINUTES);
//
// scheduledThreadPool.scheduleAtFixedRate(new ZhihuHotSearchRun(), 0, 10, TimeUnit.MINUTES);
//
// scheduledThreadPool.scheduleAtFixedRate(new WeiboTopicRun(), 0, 1, TimeUnit.DAYS);
//采集程序启动
// new WeiboHotSearchRun().start();
// new BaiduHotSearchRun().start();
// new SougoHotSearchRun().start();
// new DouyinHotSearchRun().start();
// new ZhihuHotSearchRun().start();
// new WeiboTopicRun().start();
new WeiboHotSearchRun().start();
new BaiduHotSearchRun().start();
new SougoHotSearchRun().start();
new DouyinHotSearchRun().start();
new ZhihuHotSearchRun().start();
new WeiboTopicRun().start();
//推送程序启动
new SendWeiboHotSearchRun().start();
new SendZhihuHotSearchRun().start();
......
......@@ -22,17 +22,17 @@ public class BaiduHotSearchRun extends Thread{
@Override
public void run() {
// boolean f = true;
// while(f) {
boolean f = true;
while(f) {
try {
getHotList();
// TimeUnit.MINUTES.sleep(5);
TimeUnit.MINUTES.sleep(5);
} catch (Exception e) {
e.fillInStackTrace();
// ZhiWeiTools.sleep(60*60*1000);
ZhiWeiTools.sleep(60*60*1000);
}
// ZhiWeiTools.sleep(50);
// }
ZhiWeiTools.sleep(50);
}
}
......
......@@ -21,17 +21,17 @@ public class DouyinHotSearchRun extends Thread{
@Override
public void run() {
// boolean f = true;
// while(f) {
boolean f = true;
while(f) {
try {
getHotList();
// TimeUnit.MINUTES.sleep(10);
TimeUnit.MINUTES.sleep(10);
} catch (Exception e) {
e.fillInStackTrace();
// ZhiWeiTools.sleep(60*60*1000);
ZhiWeiTools.sleep(60*60*1000);
}
// ZhiWeiTools.sleep(50);
// }
ZhiWeiTools.sleep(50);
}
}
/**
......
......@@ -20,17 +20,17 @@ public class SougoHotSearchRun extends Thread {
@Override
public void run() {
// boolean f = true;
// while(f) {
boolean f = true;
while(f) {
try {
getHotList();
// TimeUnit.MINUTES.sleep(5);
TimeUnit.MINUTES.sleep(5);
} catch (Exception e) {
e.fillInStackTrace();
// ZhiWeiTools.sleep(60*60*1000);
ZhiWeiTools.sleep(60*60*1000);
}
// ZhiWeiTools.sleep(50);
// }
ZhiWeiTools.sleep(50);
}
}
......
......@@ -21,17 +21,17 @@ public class WeiboHotSearchRun extends Thread{
@Override
public void run() {
// boolean f = true;
// while(f) {
boolean f = true;
while(f) {
try {
getHotList();
// TimeUnit.MINUTES.sleep(1);
TimeUnit.MINUTES.sleep(1);
} catch (Exception e) {
e.fillInStackTrace();
// ZhiWeiTools.sleep(60*1000);
ZhiWeiTools.sleep(60*1000);
}
// ZhiWeiTools.sleep(50);
// }
ZhiWeiTools.sleep(50);
}
}
......
......@@ -21,17 +21,17 @@ public class WeiboTopicRun extends Thread{
@Override
public void run() {
// boolean f = true;
// while(f) {
boolean f = true;
while(f) {
try {
getTopicList();
// TimeUnit.DAYS.sleep(1);
TimeUnit.DAYS.sleep(1);
} catch (Exception e) {
e.fillInStackTrace();
// ZhiWeiTools.sleep(60*60*1000);
ZhiWeiTools.sleep(60*60*1000);
}
// ZhiWeiTools.sleep(50);
// }
ZhiWeiTools.sleep(50);
}
}
......
......@@ -20,17 +20,17 @@ public class ZhihuHotSearchRun extends Thread{
@Override
public void run() {
// boolean f = true;
// while(f) {
boolean f = true;
while(f) {
try {
getHotList();
// TimeUnit.MINUTES.sleep(10);
TimeUnit.MINUTES.sleep(10);
} catch (Exception e) {
e.fillInStackTrace();
// ZhiWeiTools.sleep(60*60*1000);
ZhiWeiTools.sleep(60*60*1000);
}
// ZhiWeiTools.sleep(50);
// }
ZhiWeiTools.sleep(50);
}
}
......
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