Method main

ZezeJava/ZezeJavaTest/src/Benchmark/Simulate.java:120–216

(String[] args)

	}

	public static void main(String[] args) throws Exception {
		var lookup = MethodHandles.lookup();
		for (var arg : args) {
			var kv = arg.split("=");
			if (kv.length == 2) {
				var k = kv[0];
				if (k.endsWith("Ip"))
					lookup.findStaticVarHandle(Simulate.class, k, String.class).set(kv[1]);
				else {
					var v = Integer.parseInt(kv[1].replace("_", ""));
					if (v < 0 || v == 0 && !k.endsWith("Weight") && !k.equals("localPercent"))
						throw new IllegalArgumentException("invalid " + k + " = " + v);
					lookup.findStaticVarHandle(Simulate.class, k, int.class).set(v);
				}
			}
		}
		var procs = new ArrayList<Proc>();
		int totalWeight = 0;
		for (var f : Simulate.class.getDeclaredFields()) {
			if ((f.getType() == int.class || f.getType() == String.class) && Modifier.isStatic(f.getModifiers())) {
				var k = f.getName();
				Object v = lookup.unreflectVarHandle(f).get();
				logger.info("{} = {}", k, v);
				if (k.endsWith("Weight")) {
					totalWeight += (int)v;
					var name = k.substring(0, k.length() - 6);
					var mh = lookup.findStatic(Simulate.class, name, MethodType.methodType(long.class));
					procs.add(new Proc(name, mh, (int)v));
				}
			}
		}
		if (totalWeight <= 0)
			throw new IllegalArgumentException("invalid totalWeight = " + totalWeight);
		var totalWeight0 = totalWeight;
		keyBegin = (long)localKeyRange * serverId;
		keyEnd = keyBegin + localKeyRange;
		keyWindowBegin.set(keyBegin);

		Task.initThreadPool(Task.newFixedThreadPool(taskThreadCount, "ZezeTaskPool"),
				Executors.newScheduledThreadPool(schdThreadCount, new ThreadFactory("ZezeScheduledPool")));

		var app = new SimpleApp(serverId, 20000 + serverId + 1, 20000);
		app.getZeze().addTable("", table5 = new Table5());
		app.start();

		var totalCount = new AtomicLong();
		var lastTime = new AtomicLong(System.nanoTime());
		var state = new Object() {
			long lastCount;
		};
		for (int i = 0; i < concurrentProcs; i++) {
			var t = new Thread(() -> {
				try {
					for (; ; ) {
						var r = ThreadLocalRandom.current().nextInt(totalWeight0);
						Proc proc = null;
						for (var p : procs) {
							if ((r -= p.weight) < 0) {