Method cancelPending

ZezeJava/ZezeJava/src/main/java/Zeze/Raft/Agent.java:444–459

()

	}

	public void cancelPending() {
		// 不包括UrgentPending
		if (pending.isEmpty())
			return;

		var removed = new ArrayList<RaftRpc<?, ?>>();
		// Pending存在并发访问，这样写更可靠。
		for (var rpc : pending) {
			var r = pending.remove(rpc.getUnique().getRequestId());
			if (null != r)
				removed.add(r);
		}
		if (isDebugEnabled)
			logger.debug("Found {} RaftRpc cancel", removed.size());
		Task.getCriticalThreadPool().execute(() -> trigger(removed, "Cancel"));
	}

	private void resend(boolean immediately) {
		ConnectorProxy leader = this.leader;