Class Timer

ZezeJava/ZezeJava/src/main/java/Zeze/Component/Timer.java:54–1414

import org.jetbrains.annotations.Nullable;

public class Timer extends AbstractTimer implements HotBeanFactory {
	static final Logger logger = LogManager.getLogger(Timer.class);
	private static int CountPerNode = Reflect.inDebugMode ? 1 : 3; // 调试状态下减少timer之间的影响,以免频繁redo
	private static final BeanFactory beanFactory = new BeanFactory();
	private static final LongConcurrentHashMap<AtomicLong> exceptCounter = new LongConcurrentHashMap<>();

	public static void setCountPerNode(int countPerNode) {
		CountPerNode = Math.max(countPerNode, 1);
	}

	public static long getSpecialTypeIdFromBean(@NotNull Serializable bean) {
		return BeanFactory.getSpecialTypeIdFromBean(bean);
	}

	public static @NotNull Bean createBeanFromSpecialTypeId(long typeId) {
		try {
			return beanFactory.createBeanFromSpecialTypeId(typeId);
		} catch (Exception e) {
			if (exceptCounter.computeIfAbsent(typeId, __ -> new AtomicLong()).getAndIncrement() < 10)
				logger.error("createBeanFromSpecialTypeId({}) exception:", typeId, e);
			return new RawBean(typeId);
		}
	}

	public static long getOnlineSpecialTypeIdFromBean(@NotNull Serializable bean) {
		return bean.typeId();
	}

	public static @NotNull Bean createOnlineBeanFromSpecialTypeId(long typeId) {
		try {
			return beanFactory.createBeanFromSpecialTypeId(typeId);
		} catch (Exception e) {
			if (exceptCounter.computeIfAbsent(typeId, __ -> new AtomicLong()).getAndIncrement() < 10)
				logger.error("createOnlineBeanFromSpecialTypeId({}) exception:", typeId, e);
			return new RawBean(typeId);
		}
	}

	public final Application zeze;
	private AutoKey nodeIdAutoKey;
	AutoKey timerIdAutoKey;
	AutoKey timerSerialId;

	// 在这台服务器进程内调度的所有Timer。key是timerId，value是ThreadPool.schedule的返回值。
	final ConcurrentHashMap<String, Future<?>> timerFutures = new ConcurrentHashMap<>();
	private final HotHandle<TimerHandle> hotHandle = new HotHandle<>();
	private boolean started;

	private TimerAccount timerAccount;
	private Online defaultOnline;

	private final ConcurrentHashSet<HotModule> hotModulesHaveDynamic = new ConcurrentHashSet<>();
	private boolean freshStopModuleDynamic;

	public static @NotNull Timer create(@NotNull AppBase app) {
		return GenModule.createRedirectModule(Timer.class, app);
	}