Class Selector

ZezeJava/ZezeJava/src/main/java/Zeze/Net/Selector.java:17–261

import org.jetbrains.annotations.NotNull;

public class Selector extends Thread implements ByteBufferAllocator {
	private static final @NotNull Logger logger = LogManager.getLogger(Selector.class);

	// 以下常量为临时兼容,以后会去掉,应该改用Selectors里的
	public static final int DEFAULT_BUFFER_SIZE = 32 * 1024; // 单个buffer的字节容量
	public static final int DEFAULT_BBPOOL_LOCAL_CAPACITY = 1000; // 本地池的最大保留buffer数量
	public static final int DEFAULT_BBPOOL_MOVE_COUNT = 1000; // 本地池和全局池之间移动一次的buffer数量
	public static final int DEFAULT_BBPOOL_GLOBAL_CAPACITY = 100 * DEFAULT_BBPOOL_MOVE_COUNT; // 全局池的最大buffer数量
	public static final int DEFAULT_SELECT_TIMEOUT = 0; // 0表示无超时,>0表示每次select的超时毫秒数

	private final @NotNull Selectors selectors;
	private final @NotNull java.nio.channels.Selector selector;
	private final @NotNull ByteBuffer readBuffer; // 此线程共享的buffer,只能临时使用
	private final AtomicInteger wakeupNotified = new AtomicInteger();
	private final ArrayList<ByteBuffer> bbPool = new ArrayList<>(); // 当前selector的本地池,不会并发
	private final ConcurrentLinkedQueue<Runnable> taskQueue = new ConcurrentLinkedQueue<>();
	private long selectCount;
	private boolean firstAction;
	private volatile boolean running = true;

//	public final AtomicLong wakeupCount0 = new AtomicLong();
//	public final AtomicLong wakeupCount1 = new AtomicLong();
//	public final AtomicLong wakeupTime = new AtomicLong();
//	public long lastTime;

	public Selector(@NotNull Selectors selectors, @NotNull String threadName) throws IOException {
		super(threadName);
		setDaemon(true);
		this.selectors = selectors;
		selector = java.nio.channels.Selector.open();
		readBuffer = ByteBuffer.allocate(selectors.getReadBufferSize());
	}

	public @NotNull Selectors getSelectors() {
		return selectors;
	}

	@NotNull ByteBuffer getReadBuffer() {
		return readBuffer;
	}

	public long getSelectCount() {
		return selectCount;
	}

	public void addTask(@NotNull Runnable task) {
		taskQueue.offer(task);
	}

	@Override
	public @NotNull ByteBuffer alloc() {
		int n = bbPool.size();
		if (n <= 0) {
			var bbPoolGlobalCapacity = selectors.getBbPoolGlobalCapacity();
			if (bbPoolGlobalCapacity > 0) {
				var bbGlobalPool = selectors.getBbGlobalPool();
				int bbPoolMoveCount = selectors.getBbPoolMoveCount();
				var bbGlobalPoolLock = selectors.getBbGlobalPoolLock();