スレッドを開始する次のメソッド テストがあります。
public static void main(String[] args) throws InterruptedException {
List<Thread> threads = new ArrayList<>();
final CyclicBarrier cyclicBarrier = new CyclicBarrier(1);
Thread thread = new Thread(new CallbackThread(cyclicBarrier, threads));
threads.add(thread);
thread.start();
}
CallBack スレッドは次のようになります。
class CallbackThread implements Runnable {
CyclicBarrier cyclicBarrier;
List<Thread> threads;
CallbackThread(CyclicBarrier cyclicBarrier, List<Thread> threads) {
this.cyclicBarrier = cyclicBarrier;
this.threads = threads;
}
@Override
public void run() {
try {
cyclicBarrier.await();
} catch (InterruptedException e) {
e.printStackTrace(); //To change body of catch statement use File | Settings | File Templates.
} catch (BrokenBarrierException e) {
e.printStackTrace(); //To change body of catch statement use File | Settings | File Templates.
}
System.out.println("Threads started");
for (Thread thread1 : threads) {
try {
thread1.join();
} catch (InterruptedException e) {
e.printStackTrace(); //To change body of catch statement use File | Settings | File Templates.
}
}
System.out.println("Threads finished");
}
}
アプリケーションを実行すると、次の出力が表示されます。
Threads started
アプリケーションがハングします。
理由がわかりません。
結合ロジックをメインメソッドに置き換える場合 - すべての商品がうまくいきます。
public static void main(String[] args) throws InterruptedException {
List<Thread> threads = new ArrayList<>();
final CyclicBarrier cyclicBarrier = new CyclicBarrier(1);
Thread thread = new Thread(new CallbackThread(cyclicBarrier, threads));
threads.add(thread);
thread.start();
for (Thread thread1 : threads) {
try {
thread1.join();
} catch (InterruptedException e) {
e.printStackTrace(); //To change body of catch statement use File | Settings | File Templates.
}
}
System.out.println("Threads finished");
}
この違いを説明できますか。
私見それは同じように動作するはずです。