Method doWrite

ZezeJava/ZezeJava/src/main/java/Zeze/Net/TcpSocket.java:635–692

(@NotNull SocketChannel sc)

	 *    考虑清楚以后去掉while(true)？
	 */
	private void doWrite(@NotNull SocketChannel sc) throws Exception { // 只在selector线程调用
		sendCount++;
		int blockSize = selector.getSelectors().getBbPoolBlockSize();
		int bufSize = outputBuffer.size();
		while (true) {
			for (Action0 op; /*bufSize < blockSize * 2 &&*/ (op = operates.poll()) != null; ) {
				op.run();
				bufSize = outputBuffer.size();
			}
			var flushed = true;
			var codec = outputCodecChain;
			if (codec != null) {
				// 减慢flush频率，
				// 在保持底层outputBuffer.writeTo能满载的情况下，尽量缓冲住Chain里面的数据。
				// 这使得某些Chain算法比如Zstd能大块的工作，具有更高的效率。
				if (bufSize < blockSize) {
					codec.flush();
					int newBufSize = outputBuffer.size();
					int deltaLen = newBufSize - bufSize;
					if (deltaLen != 0) {
						bufSize = newBufSize;
						outputBufferSizeHandle.getAndAdd(this, (long)deltaLen);
					}
				} else
					flushed = false;
			}

			if (bufSize > 0) {
				var rc = outputBuffer.writeTo(sc);
				if (rc < 0) {
					close(); // 很罕见的正常关闭, 不设置异常, 其实write抛异常的可能性更大
					return;
				}
				sendSize += rc;
				outputBufferSizeHandle.getAndAdd(this, -rc);
				bufSize = outputBuffer.size();
				if (bufSize > 0) {
					// 有数据正在发送，此时可以安全退出执行，写完以后Selector会再次触发doWrite。
					// add write event，里面判断了事件没有变化时不做操作，严格来说，再次注册事件是不需要的。
					return;
				}
				// 全部都写出去了，继续尝试看看有没有新的操作。
			}
			// 时间窗口
			// 必须和把Operate加入队列同步！否则可能会出现，刚加入操作没有被处理，但是OP_WRITE又被Remove的问题。
			if (operates.isEmpty() && flushed) { // 此时bufSize=0,下次循环会触发flush
				// 真的没有等待处理的操作了，去掉事件，返回。以后新的操作在下一次doWrite时处理。
				removeInterestOps(SelectionKey.OP_WRITE);
				if (operates.isEmpty()) { // 再判断一次,避免跟submitAction的并发竞争问题
					if (closePending)
						realClose();
					return;
				}
				addInterestOps(SelectionKey.OP_WRITE);
			}
			// 发现数据，继续尝试处理。
		}
	}