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);
    }

}