?? 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);
}
}
}
}
?? 快捷鍵說明
復(fù)制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -