Method concurrentAddCount

ZezeJava/ZezeJava/src/main/java/Zeze/Raft/Test.java:222–251

(String stepName, int concurrent)

	}

	private int concurrentAddCount(String stepName, int concurrent) {
		var requests = new ArrayList<AddCount>();
		var tasks = new ArrayList<TaskCompletionSource<?>>();
		for (int i = 0; i < concurrent; ++i) {
			try {
				var req = new AddCount();
				req.setTimeout(3600_000);
				tasks.add(agent.sendForWait(req));
				// logger.debug("+++++++ {} new AddCount {}", i, req.getUnique().getRequestId());
				requests.add(req);
			} catch (Exception e) {
				//发送错误不统计。ErrorsAdd(Procedure.ErrorSendFail);
			}
			//logger.Debug("+++++++++ REQUEST {0} {1}", stepName, requests[i]);
		}
		// int i = 0;
		for (TaskCompletionSource<?> task : tasks) {
			// logger.debug("+++++++ {} wait", i++);
			task.await();
		}
		// logger.debug("+++++++ finish");
		for (var request : requests) {
			logger.debug("--------- RESPONSE {} {}", stepName, request);
			if (request.isTimeout())
				errorsAdd(Procedure.Timeout);
			else
				errorsAdd(request.getResultCode());
		}
		return tasks.size();
	}

	@SuppressWarnings("EmptyMethod")
	private void setLogLevel(@SuppressWarnings("unused") Level level) {