Многострочные потоки в Java

Question

У меня есть цикл, например for (int i=1;i<=10;i++), и я хочу создать в нем 10 потоков, каждый из которых выполнит одну и ту же задачу по набору данных и вернет результат. Затем обработайте этот результат внутри цикла. Любые идеи, как это можно сделать?

for (int i=1;i<=10;i++) { 
    Work w = new Work(); 
    Thread t = new Thread(w); 
    w.getResultFromThread(); 
    //process w 
} 

class Work implements Runnable { 
    public void run() { 
     //perform tasks 
    } 

    public int getResultFromThread() { 
      return result; 
    } 
} 

Я хочу, чтобы каждый поток работал параллельно, но когда я получаю результат один за другим.

Answer 1

Если вы не хотите использовать исполнителей, то вы можете сделать это следующим образом:

int size = 10; 
Thread[] threads = new Thread[size]; 
Work[] works = new Work[size]; 
for (int i = 1; i <= size; i++) { 

    Work w = new Work(); 
    works[i - 1] = w; 
    Thread t = new Thread(w); 
    threads[i - 1] = t; 

    // Start the thread 
    t.start(); 
} 
// now you have started all the threads 


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

    // wait for each thread to complete execution, before extracting the result 
    // [here i am assuming that getResultFromThread() does not block 
    // till we get the result, if it blocks, then no need to join] 
    threads[i].join(); 

    int result = works[i].getResultFromThread(); 
    // do something with the result 
} 

Answer 2

ArrayList<Work> listOfJobs = new ArrayList<Work>(); 
ArrayList<Thread> threadList = new ArrayList<Thread>(); 
for(int i = 0 ; i < 10; i++) { 
    Work w = new Work(); 
    listOfJobs.add(w); 
    Thread t = new Thread(w); 
    threadList.add(t); 
    t.start(); 
} 

for(Thread t : listOfJobs) { 
    t.join(); 
    w.getResultsFromThread(); 
} 

Таким образом, вы не нужны исполнители по какой-либо причине вы, возможно, не использовать их.

Сначала вы создаете все потоки и запускаете их (1-й цикл), затем вы вызываете на них join, чтобы убедиться, что поток, из которого вы хотите получить результаты, будет выполнен (2-й цикл).

Вы можете всегда передавать listOfJobs другим способом обработки результатов.