Class Task

ZezeJava/ZezeJavaTest/src/Infinite/Tasks.java:56–119

	// 所有以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();

		void verify() throws Exception {
			// default verify
			var name = getClass().getName();
			var runCount = getRunCounter(name).sum();
			var successCount = getSuccessCounter(name).sum();
			var stats = PerfCounter.instance().getOrAddProcedureInfo(name);
			var abortCount = stats.getOrAddResult(Procedure.AbortException).sum();
			var tooManyTry = stats.getOrAddResult(Procedure.TooManyTry).sum();
			Simulate.logger.info("  totalCount({})={}", name, runCount);
			Simulate.logger.info("successCount({})={}", name, successCount);
			if (abortCount != 0)
				Simulate.logger.warn("  abortCount({})={}", name, abortCount);
			if (tooManyTry != 0)
				Simulate.logger.warn("  tooManyTry({})={}", name, tooManyTry);
			if (runCount != successCount + abortCount + tooManyTry) {
				Simulate.logger.error("verify failed({}): {} != {} = {} + {} + {}\n{}",
						name, runCount, successCount + abortCount + tooManyTry, successCount, abortCount, tooManyTry,
						stats.toString(false));
				Assert.fail();
			}
		}

		@Override
		public long call() {
			var name = getClass().getName();
			var result = process();
			if (result == 0) {
				var txn = Transaction.getCurrent();
				if (txn != null)
					txn.runWhileCommit(() -> getSuccessCounter(name).increment());
				else