创建一个虚拟线程池

VirtualThreadPool

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

/**
 * @author wubo
 */
public class VirtualThreadPool {
	private static volatile ExecutorService executor;

	private VirtualThreadPool() {}

	public static ExecutorService getExecutor() {
		if (executor == null) {
			synchronized (VirtualThreadPool.class) {
				if (executor == null) {
					// 根据实际需求配置线程池参数
					int corePoolSize = 3;
					int maximumPoolSize = corePoolSize * 2;
					long keepAliveTime = 60L;
					TimeUnit unit = TimeUnit.SECONDS;
					BlockingQueue<Runnable> workQueue = new LinkedBlockingQueue<>(100);
					ThreadFactory factory = Thread.ofVirtual().factory();
					executor = new ThreadPoolExecutor(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, factory);
				}
			}
		}
		return executor;
	}

	public static void shutdown() {
		if (executor != null) {
			executor.shutdown();
			try {
				if (!executor.awaitTermination(60, TimeUnit.SECONDS)) {
					executor.shutdownNow();
					if (!executor.awaitTermination(60, TimeUnit.SECONDS)) {
						System.err.println("线程池无法终止");
					}
				}
			} catch (InterruptedException ie) {
				executor.shutdownNow();
				Thread.currentThread().interrupt();
			}
		}
	}
}