Приветствую! Подскажите, в какую сторону копать. При использовании ScheduledExecutorService, шедулер через какое-то время перестает работать, хотя процесс существует. Просто перестает выполнять то, что находится внутри Runnable.
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
33.
34.
35.
36.
37.
38.
39.
40.
41.
42.
43.
44.
45.
46.
47.
48.
49.
50.
51.
52.
53.
54.
55.
56.
public static void main(String[] args) {
schedulerOne();
schedulerTwo();
schedulerThree();
}
private static void schedulerOne() {
ThreadFactory namedThreadFactory = new ThreadFactoryBuilder().setNameFormat("thread-one").build();
ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1, namedThreadFactory);
Runnable sender = () -> {
SqlSession sqlSession = SqlMapHelper.getSqlSessionFactory().openSession(true);
try {
sqlSession.selectOne("selectTest");
} catch (Exception e) {
} finally {
sqlSession.close();
}
};
scheduler.scheduleAtFixedRate(sender, 60, 30, TimeUnit.SECONDS);
}
private static void schedulerTwo() {
ThreadFactory namedThreadFactory = new ThreadFactoryBuilder().setNameFormat("thread-two").build();
ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1, namedThreadFactory);
Runnable sender = () -> {
SqlSession sqlSession = SqlMapHelper.getSqlSessionFactory().openSession(true);
try {
sqlSession.selectOne("selectTest");
} catch (Exception e) {
} finally {
sqlSession.close();
}
};
scheduler.scheduleAtFixedRate(sender, 3, 3, TimeUnit.SECONDS);
}
private static void schedulerThree() {
ThreadFactory namedThreadFactory = new ThreadFactoryBuilder().setNameFormat("thread-three").build();
ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1, namedThreadFactory);
Runnable sender = () -> {
SqlSession sqlSession = SqlMapHelper.getSqlSessionFactory().openSession(true);
try {
sqlSession.selectOne("selectTest");
} catch (Exception e) {
} finally {
sqlSession.close();
}
};
scheduler.scheduleAtFixedRate(sender, 5, 5, TimeUnit.SECONDS);
}
