Class PerfCounter

ZezeJava/ZezeJava/src/main/java/Zeze/Util/PerfCounter.java:21–801

import org.jetbrains.annotations.Nullable;

public final class PerfCounter extends FastLock implements ZezeCounter {
	public static class LongAdderCounter extends LongAdder implements LongCounter {
		@Override
		public void inc(long v) {
			add(v);
		}
	}

	private static final LongObserver dummyLongObserver = v -> {
	};

	private static class RunInfo {
		static final int MAX_IDLE_COUNT = 10; // 最多几轮没有收集到信息就自动清除该条目

		final @NotNull String name;
		final LongAdder procCount = new LongAdder(); // 处理次数
		final LongAdder procTime = new LongAdder(); // 处理时间(ns)
		long lastProcCount;
		long lastProcTime;
		int idleCount; // 没收集到信息的轮数

		RunInfo(@NotNull String name) {
			this.name = name;
		}
	}

	private static final class RunInfoWithSerial extends RunInfo {
		final int serial;

		RunInfoWithSerial(@NotNull String name, int serial) {
			super(name);
			this.serial = serial;
		}
	}

	private static final class ProtocolInfo extends RunInfo {
		final LongAdder recvSize = new LongAdder(); // 接收字节
		final LongAdder sendCount = new LongAdder(); // 发送次数
		final LongAdder sendSize = new LongAdder(); // 发送字节
		long lastRecvSize;
		long lastSendCount;
		long lastSendSize;

		ProtocolInfo(String name) {
			super(name);
		}
	}

	/**
	 * 在Procedure中统计，由于嵌套存储过程存在，总数会比实际事务数多。
	 * 一般嵌套存储过程很少用，事务数量也可以参考这里的数值，不单独统计。
	 * 另外Transaction在重做时会在这里保存重做次数的统计。通过name和存储过程区分开来。
	 */
	public static final class ProcedureInfo {
		static final int MAX_IDLE_COUNT = 10; // 最多几轮没有收集到信息就自动清除该条目

		final @NotNull String name;
		@NotNull LongConcurrentHashMap<LongAdder> resultMap = new LongConcurrentHashMap<>();