what's the best way to make main thread to wait until all threads are finished?
for(int i=0;i<n;i++){ Thread t=new Thread(); t.start(); } //wait for all threads to finish
Create a list and wait for the all.
List<Thread> threads = new ArrayList<Thread>();
for(int i=0;i<n;i++){
Thread t=new Thread();
t.start();
threads.add(t);
}
for(Thread t: threads) t.join();
However using an ExecutorService can be a more elegant way to handle a pool of threads.
ExecutorService es = Executors.newCachedThreadPool();
for(int i=0;i<n;i++)
es.submit(new Task(n));
es.shutdown();
es.awaitTermination(timeout, TimeUnit.SECONDS);
List<Thread> threads = new ArrayList<Thread>();
for(int i=0;i<n;i++){
Thread t=new Thread();
threads.add(t);
t.start();
}
for(Thread t:threads){
t.join();
}
It can be done using thread.join( )
;.
It is also answered here already. Have a look.
Example :
class MyThread implements Runnable {
String name; // name of thread
Thread t;
MyThread(String threadname) {
name = threadname;
t = new Thread(this, name);
System.out.println("New thread: " + t);
t.start();
}
public void run() {
try {
for (int i = 5; i > 0; i--) {
System.out.println(name + ": " + i);
Thread.sleep(1000);
}
} catch (InterruptedException e) {
System.out.println(name + " interrupted.");
}
System.out.println(name + " exiting.");
}
}
public class MainClass {
public static void main(String args[]) {
MyThread ob1 = new MyThread("One");
MyThread ob2 = new MyThread("Two");
MyThread ob3 = new MyThread("Three");
System.out.println("Thread One is alive: " + ob1.t.isAlive());
System.out.println("Thread Two is alive: " + ob2.t.isAlive());
System.out.println("Thread Three is alive: " + ob3.t.isAlive());
try {
System.out.println("Waiting for threads to finish.");
ob1.t.join();
ob2.t.join();
ob3.t.join();
} catch (InterruptedException e) {
System.out.println("Main thread Interrupted");
}
System.out.println("Thread One is alive: " + ob1.t.isAlive());
System.out.println("Thread Two is alive: " + ob2.t.isAlive());
System.out.println("Thread Three is alive: " + ob3.t.isAlive());
System.out.println("Main thread exiting.");
}
}
Although the question is tagged under "java", it can be also done in C# in following ways
If you love us? You can donate to us via Paypal or buy me a coffee so we can maintain and grow! Thank you!
Donate Us With