Ajuda Thread

25 de janeiro de 2008 2 respostas

Jedi_FeniXPJ 25 de janeiro de 2008

Estou precisando de uma ajuda…
O problema é este:
Tenho que pegar no banco uma quantidade x de linhas de uma determinada tabela, com essas linhas na memória tenho que imprimir na tela só que com 5 threads.

Fiz um exemplo para melhor entendimento do problema:

class TestThread&#123;  
     
    public void execute&#40;&#41;&#123;  

     //Objeto que serve de interface com o banco de dados   
    ObejtoDAO dao = new ObjetoDAO&#40;&#41; ;  
        
     //Pega o total de linhas que existem na tabela  
     int total = dao.total&#40;&#41;;   
         
     int limit = 10;  
 
     for&#40;int i = 0; i &lt; total; i++&#41;&#123;  
            
          //Retorna as linhas do banco  
          int offset = i;  
         ArrayList arrayList = dao.getRows&#40;limit, offset&#41;;  
  
         //Nesta classe generica está o método &#40;run&#41; que eu quero executar, que no caso é imprimir um texto na tela  
         ThreadGenerica test = new ThreadGenerica&#40;&#41;;  
         ThreadGenerica test1 = new ThreadGenerica&#40;&#41;;  
   
         for&#40;int j = 0; j &lt; arrayList.size&#40;&#41;; j++&#41;&#123;  
             test.start&#40;&#41;  
              test1.start&#40;&#41;;  
         &#125;  
     &#125;  
  &#125;  
&#125;

Sempre quando executo o código dá esta exception:

Esta lógica está certa?
Desde já agradeço a ajuda de todos!!!

2 Respostas

HericksnakePJ 25 de jan. de 2008

Amigo, eu não entendi muito bem o seu problema não…
Fiquei meio em dúvida quanto ao código também.

Mas se a Thread é só pra vc ver que tudo pode sair em ordem aleatória,
tente guardar todos os dados que você resgata do banco em um Vetor ou ArrayList e com uma variável com o tamanho desse vetor ou um contador com o tamando do vetor sendo seu limite.

Faça com que esse vetor e essa variável sejam static, para você poder acessá-las pela classe que vai executar a Thread.
Crie então as cinco Threads.

Tenha em mente, que a cada impressão, você deve incrementar o contador (fazer a verificação de que ainda existe objetos no vetor).
Assim, cada Thread sua vai pegar uma única posição do vetor…

Eu vou tentar fazer um exemplo aqui e posto daqui a pouco…
Abraço!!

HericksnakePJ 25 de jan. de 2008

OLha, eu fiz o seguinte…povoei com Strings um ArrayList
Cada uma das 5 Threads vai imprimir todos os valores do ArrayList.

Note, que eu usei um Thread.sleep(Math.random());. Usei, pra deixar cada Thread rodar com um tempo sorteado de espera, mas você pode tirar esse trecho e ver que cada vez que executa ele roda de forma diferente de acordo com o escalonador do SO.

Espero que seja mais ou menos essa a sua dúvida e que eu tenha ajudado a solucionar.

import java.util.ArrayList;

public class ThreadTest &#123;

	static ArrayList &lt;String&gt; meuArray = new ArrayList&lt;String&gt;&#40;&#41;;
	static int tamArray=0;

	public static void main&#40;String&#91;&#93; args&#41; &#123;
		// TODO Auto-generated method stub
		
		meuArray.add&#40;"A"&#41;;
		meuArray.add&#40;"B"&#41;;
		meuArray.add&#40;"C"&#41;;
		meuArray.add&#40;"D"&#41;;
		meuArray.add&#40;"E"&#41;;
		meuArray.add&#40;"F"&#41;;
		meuArray.add&#40;"G"&#41;;
		meuArray.add&#40;"H"&#41;;
		meuArray.add&#40;"I"&#41;;
		
		tamArray = meuArray.size&#40;&#41;;
		
		System.out.println&#40;"Tamanho do array = "+tamArray&#41;;
		
		minhaThread t1 = new minhaThread&#40;"Thread 1"&#41;;
		minhaThread t2 = new minhaThread&#40;"Thread 2"&#41;;
		minhaThread t3 = new minhaThread&#40;"Thread 3"&#41;;
		minhaThread t4 = new minhaThread&#40;"Thread 4"&#41;;
		minhaThread t5 = new minhaThread&#40;"Thread 5"&#41;;
	
		t1.start&#40;&#41;;
		t2.start&#40;&#41;;
		t3.start&#40;&#41;;
		t4.start&#40;&#41;;
		t5.start&#40;&#41;;		
	&#125;
&#125;

class minhaThread extends Thread&#123;
	String nome;
	int contador=0;
	public minhaThread&#40;String nome&#41; &#123;
		this.nome=nome;
	&#125;
	
	public void run&#40;&#41; &#123;
		
		while&#40;contador&lt;ThreadTest.tamArray&#41;&#123;
			
			System.out.println&#40;nome +"  -- Imprimindo = "+&#40;String&#41;ThreadTest.meuArray.get&#40;contador&#41;&#41;;
						
			try &#123;
				Thread.sleep&#40;&#40;long&#41; Math.random&#40;&#41;&#41;;
			&#125; catch &#40;InterruptedException e&#41; &#123;
				// TODO Auto-generated catch block
				e.printStackTrace&#40;&#41;;
			&#125;
			contador++;
		&#125;
	&#125;
	
&#125;

Criado 25 de janeiro de 2008

Ultima resposta 25 de jan. de 2008

Respostas 2

Participantes 2

2 Respostas

Topicos relacionados