A implementação abaixo é meramente uma classe de teste para testar concorrência em Java. São criadas várias Threads que executam um método que faz uma soma, posteriormente é exibido um retorno mostrando o resultado da soma. De acordo com os valores já implementados no código abaixo, o resultado correto é 100, porém ele fica oscilando entre 90 a 100 já que por algum erro de implementação, o processo paralelo impede de sempre retornar o valor correto, exibindo o resultado sem esperar todas as Threads terminarem de executar a soma.
O que fiz de errado?
INÍCIO DA CLASSE
import java.util.ArrayList;
import java.util.List;
public class ExercicioFinal {
private final static List<Soma> listaSoma = new ArrayList<Soma>(0);
private static final int LIMITE = 10;
public static void main(final String[] args) throws InterruptedException {
for (int i = 0; i < LIMITE; i++) {
listaSoma.add(new Soma(10));
}
for (final Soma soma : listaSoma) {
new Thread(soma).start();
}
exibirResultado(0);
}
private static void exibirResultado(final int i) throws InterruptedException {
final Soma s = listaSoma.get(i);
synchronized (s) {
if (!s.foiExecutado()) {
s.wait();
}
if ((i + 1) < listaSoma.size()) {
exibirResultado(i + 1);
} else {
if (s.foiExecutado()) {
Soma.exibe();
} else {
exibirResultado(i);
}
}
}
}
}
class Soma implements Runnable {
private static int resultado;
private final int valor;
private boolean executou = false;
public Soma(final int valor) {
this.valor = valor;
}
@Override
public void run() {
synchronized (this) {
try {
Thread.sleep(1);
} catch (final InterruptedException e) {
e.printStackTrace();
}
resultado += valor;
executou = true;
this.notify();
}
}
public boolean foiExecutado() {
return executou;
}
public static void exibe() {
System.out.println(resultado);
}
}