📄 managerthread.java
字号:
package sjc;
import java.net.*;
import javax.net.ssl.*;
public class ManagerThread extends Thread {
public static Object YES = new Object();
public static Object NO = new Object();
public static Object CONNECT = new Object();
private ObjectQueue queue = new ObjectQueue();
private ListenThread lthread = new ListenThread(this);
private InterfaceThread ithread = new InterfaceThread(this);
public ObjectQueue getQueue() {
return queue;
}
public void run() {
lthread.start();
ithread.start();
//lthread.getQueue().put(new Object());
//ithread.getQueue().put(new Object());
while (!isInterrupted()) {
proceed(queue.get());
}
}
private void proceed(Object obj) {
if (obj instanceof SSLSocket) {
ithread.getQueue().put(obj);
} else {
if (obj == NO) {
lthread.getQueue().put(new Object());
} else if (obj == YES) {
ithread.getQueue().put(CONNECT);
}
}
}
}
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -