我需要你的帮助。我应该在练习中使用java.util.concurrent包,但我不知道该怎么做。问题仅与get方法有关。
public String getInput() {
if (inputList.isEmpty()) return null;
String input = inputList.get(0);
inputList.remove(0);
return input;
}
我如何编写代码以等待给定列表(变量:inputList)变为非空?
问候
最佳答案
您可以尝试使用LinkedBlockingDeque
中的java.util.concurrent
类
实现BlockingDeque
接口的软件包。
它允许您将项目添加到BlockingDeque
和take*
方法块中,直到有可用的元素,并在提取后将其删除。看看Javadoc
这是一个例子:
public class Queue {
BlockingDeque<String> inputList = new LinkedBlockingDeque<>();
public String getInput() {
try {
System.out.println("waiting on queue");
String input = inputList.takeFirst();
System.out.println("taken " + input);
return input;
} catch (InterruptedException e) {
e.printStackTrace();
return null;
}
}
public static void main(String[] args) {
Queue queue = new Queue();
new Thread(() -> {
try {
Thread.sleep(4000);
queue.inputList.add("string");
System.out.println("added string");
Thread.sleep(2000);
queue.inputList.add("string1");
System.out.println("added string 1");
} catch (InterruptedException e) {
e.printStackTrace();
}
}).start();
for (int i = 0; i < 2; i++){
queue.getInput();
}
}
}