Class Simulate

ZezeJava/ZezeJavaTest/src/Infinite/Simulate.java:16–162

import org.junit.Test;

@SuppressWarnings("NewClassNamingConvention")
public final class Simulate {
	static {
		System.getProperties().putIfAbsent("log4j2.contextSelector",
				"org.apache.logging.log4j.core.async.AsyncLoggerContextSelector");
	}

	static final Logger logger = LogManager.getLogger(Simulate.class);

	public final static int AppCount = 10;
	public final static int BatchTaskCount = 30000;
	public final static int CacheCapacity = 1000;
	public final static int AccessKeyBound = (int)(CacheCapacity * 1.2f);
	private static Simulate instance;

	public static Simulate getInstance() {
		return instance;
	}

	private final ArrayList<App> Apps = new ArrayList<>();
	private long BatchNumber;
	public boolean Infinite; // 当使用本目录的Main独立启动时，可以设置为true。

	public Simulate() {
		instance = this;
	}

	public App randApp() {
		return randApp(Apps.size());
	}

	public App randApp(int max) {
		return Apps.get(Random.getInstance().nextInt(Math.min(max, Apps.size())));
	}

	@Before
	public void Before() throws Exception {
		After();
		for (int serverId = 10; serverId < AppCount + 10; serverId++)
			Apps.add(new App(serverId));

		for (var app : Apps)
			app.Start();

		var allTFlush = new ArrayList<Zeze.Transaction.TableX<Long, BValue>>();
		var allTable1 = new ArrayList<Zeze.Transaction.TableX<Long, BValue>>();
		for (var app : Apps) {
			allTFlush.add(app.app.demo_Module1.getTflush());
			allTable1.add(app.app.demo_Module1.getTable1());
		}
		for (var app : Apps) {
			app.app.demo_Module1.getTflush().getSimulateTables = () -> allTFlush;
			app.app.demo_Module1.getTable1().getSimulateTables = () -> allTable1;
		}
	}

	@After
	public void After() throws Exception {