Method testMain

ZezeJava/ZezeJavaTest/src/Infinite/Simulate.java:93–143

()

	}

	@Test
	public void testMain() throws Exception {
		var perfScheduled = PerfCounter.instance().cancelScheduledLog();
		logger.fatal("Prepare");
		try {
			var taskDefTimeout = Task.defaultTimeout;
			Task.defaultTimeout = 86400_000;
			Tasks.prepare();
			++BatchNumber;
			logger.fatal("Run {}", BatchNumber);
			if (Apps.get(0).app.Zeze.getConfig().isHistory())
				Apps.get(0).clearTables();
			for (var app : Apps) {
				if (!app.app.Zeze.getConfig().isHistory())
					logger.info("app {} history disable.", app.app.Zeze.getConfig().getServerId());
			}
			PerfCounter.instance().resetCounter();
			logger.info("timeNow={}", CoverHistory.timeNow);
			for (int i = 0; i < BatchTaskCount; i++) {
				var app = Tasks.randCreateTask().Run();
				if (((i + 1) % 3) == 0)
					RunningTasks.add(app.coverHistory.submitTasks(i));

				//*
				if (((i + 1) % 100) == 0) {
					WaitAllRunningTasksAndClear();
				}
				// */
			}
			logger.fatal("Wait {}", BatchNumber);
			WaitAllRunningTasksAndClear();
			for (var app : Apps) {
				logger.fatal("Finish {}-{}", BatchNumber, app.getServerId());
			}
			logger.fatal("Verify {}", BatchNumber);
			for (var app : Apps)
				app.app.Zeze.checkpointRun();
			if (Apps.get(0).app.Zeze.getConfig().isHistory())
				Zeze.History.Verify.run(Apps.get(0).app.Zeze); // 只需要验证一个App，History只有一份。
			Thread.sleep(4000);
			Tasks.verify();
			Task.defaultTimeout = taskDefTimeout;
			logger.fatal("Done!!!!!!");
		} catch (Exception ex) {
			logger.error("", ex);
			throw ex;
		} finally {
			if (perfScheduled)
				PerfCounter.instance().tryStartScheduledLog();
		}
	}

	public static void main(String[] args) throws Exception {
		var simulate = new Simulate();