Class ModuleBuf

ZezeJava/ZezexJava/server/src/Game/Buf/ModuleBuf.java:16–177

import org.jetbrains.annotations.NotNull;

public class ModuleBuf extends AbstractModule implements IModuleBuf {
	private static final Logger logger = LogManager.getLogger(ModuleBuf.class);

	private Future<?> timerIdHot;
	public int counterHotTimer;

	@Override
	public int getCounter() {
		return counterHotTimer;
	}

	@Override
	public void setCounter(int value) {
		counterHotTimer = value;
	}

	public static class HotTimer implements TimerHandle {
		@Override
		public void onTimer(@NotNull TimerContext context) throws Exception {
			var mc = context.timer.zeze.getHotManager().getModuleContext("Game.Buf", IModuleBuf.class);
			var ibuf = mc.getService();
			var buf = (BBuf)context.customData;
			var count = ibuf.getCounter();
			if (buf.getId() != count)
				throw new RuntimeException("buf " + buf.getId() + ":" + count);
			buf.setId(count + 1);
			Transaction.whileCommit(() -> ibuf.setCounter(count + 1));
		}
	}

	@Override
	public void StartLast() {
		counterHotTimer = 0;
		_tbufs.getChangeListenerMap().addListener(new BufChangeListener("Game.Buf.Bufs"));
		var rand = Zeze.Util.Random.getInstance();
		timerIdHot = Task.scheduleUnsafe(
				rand.nextLong(3000) + 1000,
				rand.nextLong(3000) + 1000,
				() -> {
					var module = App.Zeze.getHotManager().getModuleContext("Game.Equip", IModuleEquip.class);
					var service = module.getService();
					oldAccess = service.hotHelloWorld(oldAccess);
				});

		Task.call(App.Zeze.newProcedure(() -> {
			hotTimerId = App.Zeze.getTimer().schedule(
					rand.nextLong(3000) + 1000, rand.nextLong(3000) + 1000,
					HotTimer.class, new BBuf());
			return 0;
		}, "hotTimer"));
	}

	int oldAccess = 0;

	public final void Start(App app) {
	}

	String hotTimerId;