Мне нужно вычислить сложное математическое выражение, поэтому я сделал его декомпозицию, чтобы разбить его вычисление на разные потоки.
У меня есть поток №1 и поток №3. В потоке №1 я вычисляю y1 = A*b
, а в потоке №3 я вычисляю Y3 = A2C2-B2A2
. После этого я хочу передать Y3
в поток №1 для вычисления Y3y1
. Для того, чтобы подождать пока завершится поток №3, я в первом потоке вызвал метод thread3.join();
, но он у меня почему-то не работает и в итоге во время вычисления Y3y1
выскакивает NullPointerException
. Если же я просто усыплю поток №1 на несколько секунд до передачи Y3
в него, то все работает нормально. Так почему же у меня не работает метод join? И можете дать рекомендации по решению задачи и написания кода к ней?
Вот часть моего кода
thread1 = new Thread(
new Runnable() {
@Override
public void run() {
b = calc_b();
matrixA = generateMatrixA(matrixOrder);
y1 = calc_y1(matrixA, matrixOrder);
// Не работает!
try {
thread3.join();
} catch (Exception e) {
}
// Если сделаю так, то работает.
// try {
// thread1.sleep(4000);
// } catch (InterruptedException e) {
// e.printStackTrace();
// }
Y3new = Y3;
calc_Y3y1(Y3new, y1, matrixOrder);
}
}
);
thread3 = new Thread(
new Runnable() {
@Override
public void run() {
matrixA2 = generateMatrixA2(matrixOrder);
matrixB2 = generateMatrixB2(matrixOrder);
matrixC = generateMatrixC(matrixOrder);
Y3 = calc_Y3(matrixA2, matrixB2, matrixC, matrixOrder);
}
}
);
thread1.start();
thread3.start();
.join()
?try-catch
необходим, т.к.join
может выброситьInterruptedException
, что, конечно, не оправдывает перехват всех исключений и отсутствие логирования. Плюс нужно поменять местами старты потоков, чтобы гарантировать, что к моментуthread3.join()
поток будет запущен (при незапущеном потоке join выйдет сразу). Но да, как в ответе @Etki, вам нужно ждать не потоки, а данные. Чтобы привести пример кода черезCompletableFuture
вашего кода слишком мало...