📄 objectqueue.java
字号:
/*
public void run(){
while (!isInterrupted()) {
proceed(queue.get());
}
}
private void proceed(Object obj) {
}
*/
//an optimized version of this class is available
package sjc;
import java.util.*;
public class ObjectQueue {
private LinkedList queue = null;
private volatile int objects = 0;
public ObjectQueue() {
queue = new LinkedList();
}
public synchronized Object get() {
try {
while (objects == 0) {
notifyAll();
wait(1000);
}
objects--;
return queue.removeLast();
} catch (Exception e) {
e.printStackTrace();
return null;
}
}
public synchronized void put(Object obj) {
try {
notifyAll();
queue.addFirst(obj);
objects++;
} catch (Exception e) {
e.printStackTrace();
}
}
}
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -