WriteEventCheckRunner.java 397 Bytes
package io.mycat.net;

public class WriteEventCheckRunner implements Runnable {
	private final SocketWR socketWR;
	private volatile boolean finshed = true;

	public WriteEventCheckRunner(SocketWR socketWR) {
		this.socketWR = socketWR;
	}

	public boolean isFinished() {
		return finshed;
	}

	@Override
	public void run() {
		finshed = false;
		socketWR.doNextWriteCheck();
		finshed = true;
	}
}