Skip to main content
3 de 4
Adição de novas informações.

Threads no Java

É primeira vez que estou trabalhando com Threads. Criei duas threads, uma para rodar o gerador de relatórios (iReport) e outra para operar uma barra de progresso (JProgressBar). No entanto, mesmo usando flag, a Thread não é terminada (state - TERMINATED), ou seja, continua no estado RUNNABLE. Vejam:

package util;

import java.io.InputStream;
import java.sql.ResultSet;
import java.util.Map;
import java.util.concurrent.atomic.AtomicBoolean;
import javax.swing.JProgressBar;
import visao.TelaRelatorioCadastral;

/**
 *
 * @author JFSJUNIOR
 */
public class ControlaThread{
    private Thread threadBarraProgresso;
    private Thread threadEmissaoRelatorio;
    private final AtomicBoolean rodando = new AtomicBoolean(false);
    private JProgressBar progresso;
    private InputStream fluxo;
    private ResultSet dados;
    private TelaRelatorioCadastral tela;
    private Map param;
    
    public ControlaThread(JProgressBar barraProgresso, 
            InputStream caminho, ResultSet resultados, 
            TelaRelatorioCadastral telaCad, Map paramentros){
        progresso = barraProgresso;
        fluxo = caminho;
        dados = resultados;
        tela = telaCad;
        param = paramentros;
    }
    
    public void start(){
        threadBarraProgresso = new Thread(new Runnable(){
            @Override
            public void run() {
                rodando.set(true);
                while(progresso.getValue() < 100 && rodando.get()){
                    try {
                        Thread.sleep(100);
                        progresso.setValue(progresso.getValue() + 10);
                    } catch (InterruptedException iex) {
                        System.out.println("ERRO: " + iex.getMessage());
                    }
                }
            }
        });
        
        threadEmissaoRelatorio= new Thread(new Runnable(){
            @Override
            public void run() {
                if(rodando.get())
                    GeradorDeRelatorio.gerarRelatorio(fluxo, param, dados, tela);
            }
        });
        
        threadBarraProgresso.start();
        threadEmissaoRelatorio.start();
    }
    
    public void stop(){
        rodando.set(false);
        System.out.println("Finalizado");
    }
}

Tudo funciona, mas a tela que chama essa classe sempre vem setada com a última opção escolhida (em um JComboBox) e a barra de pregresso vem completada (100%). Como parar as Threads sem usar o depreciado stop(), pois com as flags não está funcionando? Onde estou errando?

Informações adicionais

1 - Verificando o nome das threads no método stop:

public void stop(){
        rodando.set(false);
        System.out.println("Finalizado");
        System.out.println("NomeThreadBE: " + threadBarraProgresso.getName());
        System.out.println("NomeThreadER: " + threadEmissaoRelatorio.getName());
}

gera:

run:
Finalizado
NomeThreadBE: Thread-2
NomeThreadER: Thread-3

Aqui o método do botão:

private void btnGerarActionPerformed(java.awt.event.ActionEvent evt) {                                         
        if(cbxItemRelatorio.getSelectedIndex() != OPCAO_INVALIDA){
            int opcao =  cbxItemRelatorio.getSelectedIndex();
            InputStream stream;
            ResultSet resultSet;
            Connection conexao;
            ControlaThread controle;
            parametros.put("logo", "/img/");
            parametros.put("SUBREPORT_DIR", "/relatorio/");
            terminado = false;
            
            try{
                switch(opcao){
                    case 1:
                        stream = getClass().getResourceAsStream(
                                "/relatorio/rc_plano_conta.jasper");
                        resultSet = dao.ContaContabil.retornarPlanoContas();
                        conexao = null;
                        
                        construirRelatorio(stream, resultSet, conexao, this);
                        break;
                    case 5:
                        stream = getClass().getResourceAsStream(
                                "/relatorio/rc_cliente.jasper");
                        resultSet = null;
                        conexao = ConectaBancoDeDados.getConexao();
                        
                        construirRelatorio(stream, resultSet, conexao, this);
                        break;
                    case 9:
                        stream = getClass().getResourceAsStream(
                                "/relatorio/rc_raca.jasper");
                        resultSet = dao.Raca.retornarRelatorioRaca();
                        conexao = null;
                        
    
                        controle = new ControlaThread(barraProgresso, stream, resultSet, this, parametros);
                        controle.start();
                        controle.stop();
                        break;
                }
            }catch(SQLException sqle){
                System.out.println("ERRO: " + sqle.getMessage());
                JOptionPane.showMessageDialog(this, "Relatório não foi gerado. " 
                    + sqle.getMessage());
            }
        }else{
             JOptionPane.showMessageDialog(this, "Opção inválida!");
        }
    }

Obs.: Como eu só construí o relatório de raças, estou usando o case 9 para os testes.

Desde já agradeço.