Method CsQueue

ZezeJava/ZezeJava/src/main/java/Zeze/Collections/CsQueue.java:25–43

为了测试公开这个方法，应用应该去使用Queue.Module.open.

(Queue.Module module, String name, int serverId, Class<V> valueClass, int nodeSize)

	 * 为了测试公开这个方法，应用应该去使用Queue.Module.open.
	 */
	public CsQueue(Queue.Module module, String name, int serverId, Class<V> valueClass, int nodeSize) {
		this.module = module;
		this.name = name;
		this.queue = module._open(name + "@" + serverId, valueClass, nodeSize);

		var out = new OutLong();
		Task.call(module.zeze.newProcedure(() -> {
			var root = queue.getOrAddRoot();
			root.setLastNodeId(root.getLoadSerialNo() + 1);
			out.value = root.getLoadSerialNo();
			return 0;
		}, "increaseLoadSerialNo"));
		var offlineNotify = new BOfflineNotify();
		offlineNotify.serverId = module.zeze.getConfig().getServerId();
		offlineNotify.notifySerialId = out.value;
		offlineNotify.notifyId = "Zeze.Collections.CsQueue.OfflineNotify";
		module.zeze.getServiceManager().offlineRegister(offlineNotify,
				(notify) -> splice(notify.serverId, notify.notifySerialId));
	}

	public long getLoadSerialNo() {
		var out = new OutLong();