我使用了下面类似的程序来实现多线程来运行并行进程,但在完成几个进程之前,我的线程正在移动到另一个(或)它没有完全完成进程,我正在写大约5个文件与数据并行每个线程,其中5个文件,有时4个文件只写入。private final int wait; this.wait = code;
}Callable<Result> c = new Callabl
我正在创建自己的线程池和未来的对象,可以执行可调用接口并行。Executor提供关闭方法来停止所有工作线程的运行。如果我创建的线程池如下所示,那么在所有线程完成执行之后,我应该如何实现关闭方法以停止?我的自定义线程池看起来像{
private final java.util.concurrent.BlockingQueue