package com.shlanbao.tzsc.utils.tools;
|
|
import java.util.concurrent.ExecutorService;
|
import java.util.concurrent.Executors;
|
import java.util.concurrent.ScheduledExecutorService;
|
import java.util.concurrent.TimeUnit;
|
/**
|
* 线程管理
|
* @author Leejean
|
* @create 2015年1月7日下午1:20:18
|
*/
|
public class ThreadManager {
|
|
private static ThreadManager threadManager = null;
|
private ExecutorService executorService = Executors.newCachedThreadPool();
|
private ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(10);
|
|
private ThreadManager(){
|
|
}
|
|
public static ThreadManager getInstance(){
|
if(threadManager == null){
|
threadManager = new ThreadManager();
|
}
|
return threadManager;
|
}
|
|
/***
|
* 新增执行线程
|
* @param command
|
*/
|
public void add(Runnable command){
|
executorService.execute(command);
|
}
|
|
/***
|
* 增加定时执行线程
|
* @param command
|
* @param initialDelay
|
* @param delay
|
* @param unit
|
*/
|
public void addSchedule(Runnable command,int initialDelay,int delay,TimeUnit unit){
|
scheduledExecutorService.scheduleWithFixedDelay(command, initialDelay, delay, unit);
|
}
|
|
public void shutDownThread() {
|
scheduledExecutorService.shutdown();
|
}
|
|
}
|
