package org.yeshi.utils;
|
|
import java.util.concurrent.LinkedBlockingQueue;
|
import java.util.concurrent.ThreadPoolExecutor;
|
import java.util.concurrent.TimeUnit;
|
|
/**
|
* @author hxh
|
* @title: ThreadUtil
|
* @description: TODO
|
* @date 2021/12/2 17:50
|
*/
|
public class ThreadUtil {
|
|
private static LinkedBlockingQueue<Runnable> queue=new LinkedBlockingQueue<Runnable>(100);
|
|
private static ThreadPoolExecutor threadPoolExecutor=new ThreadPoolExecutor(30, 3000, 20, TimeUnit.SECONDS, queue);
|
|
static{
|
threadPoolExecutor.allowCoreThreadTimeOut(true);
|
}
|
|
public static void run(Runnable runnable){
|
threadPoolExecutor.execute(runnable);
|
}
|
|
}
|
