Method splice

ZezeJava/ZezeJava/src/main/java/Zeze/Collections/CsQueue.java:59–95

为了测试了公开的，调用也是可以的，但要小心。 @param serverId serverId @param loadSerialNo loadSerialNo

(int serverId, long loadSerialNo)

	 * @param loadSerialNo loadSerialNo
	 */
	public void splice(int serverId, long loadSerialNo) {
		if (serverId == module.zeze.getConfig().getServerId())
			return; // skip self

		Task.call(module.zeze.newProcedure(() -> {
			// 接管别的服务器的队列时。
			var srcName = name + "@" + serverId;
			var src = Queue.compatible(module._tQueues.get(srcName), srcName);
			if (null == src || src.getHeadNodeKey().getNodeId() == 0 || src.getTailNodeKey().getNodeId() == 0)
				return 0L; // nothing need to do.

			if (src.getLoadSerialNo() != loadSerialNo)
				return 0L; // 需要接管的机器已经活过来了。

			// prepare splice
			var dstName = name + "@" + module.zeze.getConfig().getServerId();
			var dstRoot = Queue.compatible(module._tQueues.getOrAdd(dstName), dstName);
			var srcTailNodeKey = src.getTailNodeKey();
			var srcTail = Queue.compatible(srcTailNodeKey, module._tQueueNodes.get(srcTailNodeKey));

			if (null == srcTail)
				throw new IllegalStateException("maybe operate before entry created.");

			// 这是新接管过来的nodeKey范围，如果需要对新接管数据进一步事务外处理，使用out送出事务外。
			//first.value = new BQueueNodeKey(srcName, src.getHeadNodeId());
			//last.value = new BQueueNodeKey(dstName, dstRoot.getHeadNodeId());

			// splice 单向链表，新接管的数据拼到开头。
			srcTail.setNextNodeKey(dstRoot.getHeadNodeKey());
			dstRoot.setHeadNodeKey(src.getHeadNodeKey());
			// clear src
			var nullKey = new BQueueNodeKey();
			src.setHeadNodeKey(nullKey);
			src.setTailNodeKey(nullKey);
			return 0L;
		}, "CsQueue.splice"));
	}

	public String getName() {
		return name;