6

Estou com uns problemas no entendimento completo do código pois sou novo na utilização do java em thread. O que código vai fazer é controlar o fluxo, fazendo 55 iterações dividindo entre a thread e programa principal (main):

Resultado:
Main Thread.: 1
New Thread..: 2
Main Thread.: 3
New Thread..: 4
...
Main Thread.: 51
New Thread..: 52
Main Thread.: 53
New Thread..: 54

Até aí tudo bem , o problema está , quando em certa execução o programa entra em alguns loop infinito e não para de executar outra vezes ele completa a execução , queria ajuda para entender este problema.

/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 /
package testando;

/*
 *
 * @author Márcio
 */
public class Testando {
static int value = 0;
static int flag = 1;

@SuppressWarnings("empty-statement")
    public static void main(String[] args) {

                class MyThread extends Thread {

                        @Override
                        public void run() {
                                while(flag == 1);
                                while(++value < 55) {
                                        System.out.println("New Thread..: " + value);
                                        flag = 1;
                                        while( value < 55 && flag == 1);
                                }
                        }
                }

                Thread thread1 = new MyThread();
                thread1.start();
                System.out.println(flag == 0);
                while(flag == 0);
                while(++value < 55) {
                        System.out.println("Main Thread.: " + value);
                        flag = 0;
                        while( value < 55 && flag == 0);
                }
        }
    }
3
  • 1
    while(flag == 1); pra que isso? Commented 7/04/2014 às 22:48
  • Meu estava testando aqui, vir o código executar sem está função, e sem também while(flag == 0); , peço que desconsidere esta parte. Commented 7/04/2014 às 23:03
  • Poderia remover as tags desnecessárias dentro da sua pergunta e do código? Commented 7/04/2014 às 23:34

1 Resposta 1

4

O que está causando racing conditions no seu código é o fato do acesso às variáveis não ser atômica, isto é, elas são acessadas concorrentemente por mais de um thread. Se você quer que essas variáveis sejam usadas pelo código sem que a operação executada em um thread afete a operação executada pelo outro, você deve encapsular as operações de leitura e alteração do valor das variáveis em blocos synchronized (dentro dos quais somente pode entrar um thread de cada vez) ou então usar objetos que garantam a atomicidade da operação como por exemplo AtomicInteger.

5
  • O problema é esse mesmo, mas acho que AtomicInteger não vai adiantar nesse caso porque o incremento e o teste da variável acontecem em locais separados.
    – utluiz
    Commented 8/04/2014 às 15:27
  • É verdade. Mas as operações de incremento e teste não precisam ser dentro do mesmo bloco synchronized, apenas cada uma delas deve ser atômica, não? A API de AtomicInteger talvez resolva isso, com métodos como por exemplo compareAndSet(). Ou essa mesma API pode permitir que o par de ações em si seja atômico.
    – Piovezan
    Commented 8/04/2014 às 17:44
  • Não havia analisado o código com calma. Se for reescrito de maneira adequada o AtomicInteger provavelmente resolve. O problema é que o código está meio gambiarrado, esses loops "infinitos" ali para fazer sincronização não me cheiram bem.
    – utluiz
    Commented 8/04/2014 às 17:57
  • 1
    Ah, sim. Provavelmente o OP necessita de uma solução com wait() e notify()/notifyAll() para permitir que os threads se alternem no incremento da variável, dispensando uma flag de controle.
    – Piovezan
    Commented 8/04/2014 às 18:47
  • Um Semaphore, um CountDownLatch ou uma ReentrantLock com duas Conditions também podem ser usados para evitar a espera ocupada e a flag. Commented 9/04/2014 às 16:20

Você deve fazer log-in para responder a esta pergunta.

Esta não é a resposta que você está procurando? Pesquise outras perguntas com a tag .