У меня есть класс который дочерний классу Thread
. У него есть поле которое нужно для бизнес логики, как результат выполнения потока. И мне надо, это поле получить в основном потоке. Но я не всегда успеваю получить значение этого поля, так как run()
заканчивает свою работу раньше, чем я успеваю его прочитать.
А мне надо успеть получить результаты каждого потока, и в том порядке, в котором они выполнились. Помогите пожалуйста кто чем может. У меня есть мысль может эти результаты записывать в очередь, но если она будет на полях Consumer
, то будет та же проблема... Как это решить?
public class Consumer {
private Storage storage;
public Consumer() {
this.storage = new UserStorage();
}
public boolean addAccount(BigDecimal amount, String name, Integer id) throws InterruptedException {
ThreadAdd thread = new ThreadAdd(amount, name, id);
thread.start();
boolean result = thread.added;
// здесь печатает result = false
System.out.println(result + " add");
return result;
}
private class ThreadAdd extends Thread {
private volatile boolean added;
private BigDecimal amount;
private String name;
private Integer id;
private ThreadAdd(BigDecimal amount, String name, Integer id) {
this.amount = amount;
this.name = name;
this.id = id;
}
@Override
public void run() {
this.add();
// здесь печатает result = true
System.out.println(Thread.currentThread().getName() + " run = " + added);
}
private void add() {
final Account account = new User(this.amount, this.name, this.id);
this.added = Consumer.this.storage.addAccount(account);
}
}