Class Tasks

ZezeJava/ZezeJavaTest/src/Infinite/Tasks.java:24–411

import org.junit.Assert;

public final class Tasks {
	public static final boolean debugTradeSum = false;
	private static final ConcurrentHashMap<String, LongConcurrentHashMap<LongAdder>> CounterKey = new ConcurrentHashMap<>();
	private static final ConcurrentHashMap<String, LongAdder> CounterRun = new ConcurrentHashMap<>();
	private static final ConcurrentHashMap<String, LongAdder> CounterSuccess = new ConcurrentHashMap<>();

	static LongConcurrentHashMap<LongAdder> getKeyCounters(String name) {
		return CounterKey.computeIfAbsent(name, __ -> new LongConcurrentHashMap<>());
	}

	static LongAdder getKeyCounter(String name, long key) {
		return getKeyCounters(name).computeIfAbsent(key, __ -> new LongAdder());
	}

	static LongAdder getRunCounter(String name) {
		return CounterRun.computeIfAbsent(name, __ -> new LongAdder());
	}

	static LongAdder getSuccessCounter(String name) {
		return CounterSuccess.computeIfAbsent(name, __ -> new LongAdder());
	}

	static void clearAllCounters() {
		CounterKey.clear();
		CounterRun.clear();
		CounterSuccess.clear();
		Table1Long2Add1.commitCount.reset();
		tflushInt1TradeConcurrentVerify.keys = null;
	}

	// 所有以long为key的记录访问可以使用这个基类。
	// 其他类型的key需要再定义新的基类。
	static abstract class Task implements FuncLong {
		final Set<Long> Keys = new HashSet<>();
		demo.App App;

		int getKeyNumber() {
			return 1;
		}

		int getKeyBound() {
			return Simulate.AccessKeyBound;
		}

		boolean IsProcedure() {
			return true;
		}

		App Run() throws ExecutionException, InterruptedException {
			var app = Simulate.getInstance().randApp();
			app.Run(this);
			return app;
		}

		void prepare() throws Exception {
		}

		abstract long process();