SpringContext中的循环任务优化,添加业务监控

admin

2020-07-29 c338aa60df58bee9f4c25afedf94fe6930a119c1

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
package com.yeshi.fanli.service.impl;
 
import com.aliyun.openservices.shade.com.alibaba.rocketmq.common.ThreadFactoryImpl;
import org.yeshi.utils.TimeUtil;
 
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.TimeUnit;
 
public class JobThreadExecutorServiceImpl {
 
    private ScheduledExecutorService scheduledExecutorService;
 
    public JobThreadExecutorServiceImpl() {
        scheduledExecutorService = Executors.newSingleThreadScheduledExecutor(new ThreadFactory() {
            @Override
            public Thread newThread(Runnable r) {
                Thread thread = new Thread(r);
                thread.setDaemon(true);
                return thread;
            }
        });
    }
 
 
    public void run(Runnable runnable) {
        scheduledExecutorService.scheduleAtFixedRate(runnable, 1000 * 1, 1000, TimeUnit.MILLISECONDS);
    }
 
 
}