Class Task

ZezeJava/ZezeJava/src/main/java/Zeze/Util/Task.java:30–1134

import org.jetbrains.annotations.Nullable;

public final class Task {
	// 通常不建议开,事务并发量太大时并发冲突可能很高导致频繁redo
	private static final boolean USE_VIRTUAL_THREAD = PropertiesHelper.getBool("useVirtualThread", true);
	private static final boolean USE_UNLIMITED_VIRTUAL_THREAD = USE_VIRTUAL_THREAD
			&& PropertiesHelper.getBool("useUnlimitedVirtualThread", !inJUnitTest());

	// 默认不开启热更，这个实现希望能被优化掉，几乎不造成影响。
	// 开启热更时，由App.HotManager初始化的时候设置。
	@SuppressWarnings("CanBeFinal")
	public static volatile @NotNull Factory<HotGuard> hotGuard = () -> null;
	private static final FastLock taskLock = new FastLock();
	private static final TaskOneByOneByKey oneByOne = new TaskOneByOneByKey();

	@FunctionalInterface
	public interface ILogAction {
		void run(@Nullable Throwable ex, long result, @Nullable Protocol<?> p, @NotNull String actionName);
	}

	@SuppressWarnings("CanBeFinal")
	public static volatile long defaultTimeout = 120_000; // 2 minutes

	static final @NotNull Logger logger = LogManager.getLogger(Task.class);
	private static ExecutorService threadPoolDefault;
	private static ScheduledExecutorService threadPoolScheduled;
	private static ExecutorService threadPoolCritical; // 用来执行内部的一些重要任务，和系统默认 ThreadPool 分开，防止饥饿。
	// private static final ThreadPoolExecutor rpcResponseThreadPool
	//			= (ThreadPoolExecutor)Executors.newCachedThreadPool(new ThreadFactoryWithName("ZezeRespPool"));
	@SuppressWarnings("CanBeFinal")
	public static @Nullable ILogAction logAction = Task::DefaultLogAction;

	static {
		ShutdownHook.init();
	}

	public static boolean isVirtualThreadEnabled() {
		return ThreadFactoryWithName.isVirtualThreadEnabled();
	}

	public static boolean inJUnitTest() {
		return System.getProperty("sun.java.command").split(" ")[0].endsWith(".JUnitStarter");
	}

	public static @NotNull TaskOneByOneByKey getOneByOne() {
		return oneByOne;
	}

	public static ExecutorService getThreadPool() {
		return threadPoolDefault;
	}

	public static ScheduledExecutorService getScheduledThreadPool() {
		return threadPoolScheduled;
	}

	public static @NotNull ExecutorService getCriticalThreadPool() {
		return threadPoolCritical;
	}