我已经在newFixedThreadPool方法中初始化了ConcurrentLinkedQueue类型的局部valiable,并调用了参数化构造函数来初始化runnable成员变量。import java.util.concurrent.ConcurrentLinkedQueue;
}
public MyExecuterService ne
Buffer类具有write和read方法。缓冲区由多个线程使用。生成数据的线程使用write方法向缓冲区写入数据值;使用数据的线程调用read方法从缓冲区获取下一个数据值。下面的代码在只有一个线程时工作,但是当使用多个线程时,read和write方法是不正确的。public class Buffer<E> {
private List