Java 中的线程作业

Question

我想在 Java 中同时生成 200 个线程。我现在正在做的是进入一个循环并创建 200 个线程并启动它们。完成这 200 个线程后，我想再生成 200 个线程集，依此类推。

这里的要点是，我生成的前 200 个线程需要在生成下一组之前完成。我尝试了下面的代码，但它不起作用

for(int i=0;i<200;i++){
    Thread myThread = new Thread(runnableInstance);
    myThread.start();
}
for(int i=0;i<200;i++){
    Thread myThread = new Thread(runnableInstance);
    myThread.start();
}

注意：我有意将 for 循环放了两次，但我想要的效果并没有发生，因为第二个 for 循环是在第一组线程结束执行之前执行的。

请指教

Answer 1

您应该保留已创建线程的列表。然后，一旦您启动了所有这些，您就可以遍历列表并对每个列表执行join。当连接循环完成时，您的所有线程都将运行完成。

List<Thread> threads = new List<Thread>();
for(int i=0;i<200;i++){
    Thread myThread = new Thread(runnableInstance);
    myThread.start();
    threads.add(myThread);
}
//All threads are running
for(Thread t : threads) {
    t.join();
}
//All threads are done

Answer 2

另一种解决方案是使用 Latch

final CountDownLatch latch = new CountDownLatch(200);

  for(int i=0; i<10; i++)
{

 Thread thread = new Thread()
{
    public void run()
{
     try{
         //do your work  

     }finally{
      latch.countDown();
     }
    }
   };

     }  
            //will block here util your threads all finished
  latch.await();

Answer 3

如果您使用的是 Java 1.5，请使用并发包，如果您使用的是 Java 1.4.2，则该包仍然可以作为反向端口使用，我很确定。

话虽如此，我最近有类似的任务要做；你可以很容易地通过使用ExecutorService 来实现它，你可以通过wait on the Future object to return 知道你的任务是否完成。非常干净的模式 - 也许不完全是您想要实现的目标，但在现实生活中它工作得非常好:-)。

一些代码：

BlockingQueue<Runnable> workQueue = new LinkedBlockingQueue<Runnable>();
taskExecutor = new ThreadPoolExecutor(200, 200, 30, TimeUnit.SECONDS, workQueue);

futureList.add(taskExecutor.submit(new MyCallable()));

for (Future<Object> future : futureList) {
    future.get(); // wait for the task to complete
}

//... instantiate your second group of executors

Answer 4

某种伪代码，你需要实例化可调用的;-)

while( moreThreads ) {
    List<Callable<Integer>> threads = new ArrayList<Callable<Integer>>();
    for( int i = 0; i < 200; ++i ) {
        threads.add(new Callable<Integer>() );
    }

    FixedThreadPool pool = Executers.newFixedThreadPool(200);
    pool.invokeAll(threads);
    pool.shutdown();
}

Answer 5

感觉是功课，但是...

spawnAndWait() {
 Thread T[] = new Thread[n];
 for(int i=0;i<n;i++){
     T[i] = new Thread(runnableInstance);
     T[i].start();
 }
 for (Thread t : T) {
  t.join();
 }
}

Answer 6

您需要使用join() 等待线程完成：

// run first set of threads
List<Thread> threads = threadsList; // save reference to all threads
for(Thread t : threads){
    t.join();
}
// all threads finished

// run other set of threads