Class Env

ZezeJava/ZezeJavaTest/src/SimpleRaft/RaftTest.java:14–159

public final class RaftTest {
	private final class Env implements Raft.Env {
		private final SimpleDateFormat dtf = new SimpleDateFormat("yy-MM-dd HH:mm:ss.SSS");
		private final Date date = new Date(0);
		private final FieldPosition fieldPos = new FieldPosition(0);
		private final StringBuffer strBuf = new StringBuffer();
		private final ArrayDeque<Object> events = new ArrayDeque<>(16);
		private final ArrayDeque<Object> clientEvents = new ArrayDeque<>(16);
		private final HashMap<Long, Raft.Log> logMap = new HashMap<>();
		private Raft.Log @NotNull [] logs = new Raft.Log[4]; // 初始容量
		private long logCount; // logs的有效数量
		private long randSeed;
		private final int id;
		private final Raft raft;

		Env(int id) {
			this.id = id;
			randSeed = (id + 123456789L) * 987654321L;
			raft = new Raft(this, RAFT_COUNT, id, curTime);
		}

		@NotNull Raft getRaft() {
			return raft;
		}

		@Override
		public long getCurTime() {
			return curTime;
		}

		@Override
		public int random(int max) {
			long s = randSeed * 6364136223846793005L + 1442695040888963407L;
			randSeed = s;
			return (int)(((s >>> 32) * max) >>> 32);
		}

		@Override
		public @Nullable Object recvEvent() {
			return events.pollFirst();
		}

		@Override
		public void sendEvent(int id, @NotNull Object obj) {
			envs[id].events.addLast(obj);
		}

		@Nullable Object recvClientEvent() {
			return clientEvents.pollFirst();
		}

		@Override
		public void sendClientEvent(@NotNull Object obj) {
			clientEvents.addLast(obj);
		}

		@Override
		public long getLogCount() {
			return logCount;