[java] Multithread

[caimano73]

ciao a tutti,
ho una procedura in java che esegue delle operazioni su una tabella.
I record che esamina sono molti, e la procedura impiega quasi un'ora e mezza per finire.
La macchina su cui gira sta cosa ha 4 processori, ma la procedura sembra che giri su una solo cpu.
Allora ho provato a creare quattro 3d che si smazzano ciascuno un quarto dei record.
Il mio problema è che non riesco a farli partire in parallelo.
Cioè se io faccio
thred1.start();
trhed2.start();

il secondo 3d aspetta che il primo sia terminato per partire.
Come posso fare a farli partire in contemporanea?
Ho provato anche a metterli in un unico threadgroup, ma non cambia nulla.

Help me please!!!!

[floyd]

ma se il primo thread inizia una transazione sul database l'altro thread deve aspettare che il primo committi la tran

[caimano73]

Originariamente inviato da floyd
ma se il primo thread inizia una transazione sul database l'altro thread deve aspettare che il primo committi la tran

questo mi fa benissimo, ed infatti la connessione al db è in autocommit true.
Il problema è che io vedo che il secondo 3d proprio non parte finchè non ha finito il primo.

[floyd]

scrivi il codice

[caimano73]

questo è il codice.
La procedura principale fa questo:

    
  ThreadGroup tg = new ThreadGroup("pippo");

  ThreadForzaConsuntivi tfc1 = 
   new ThreadForzaConsuntivi(tg, m_con, minWp, minWp + diff,
                                   dataInizio, dataFine,1);

  ThreadForzaConsuntivi tfc2 = 
   new ThreadForzaConsuntivi(tg, m_con, minWp + diff, maxWp,
                                   dataInizio, dataFine,2);
  tfc1.start();
  tfc2.start();

La classe ThreadForzaConsuntivi estende la classe Thread ed ha questi metodi

    
  public ThreadForzaConsuntivi(ThreadGroup tg, Connection m_con, 
                               int wpInizio, int wpFine, 
                               String dataInizio, String dataFine, 
                               int num3d) {
    super(tg, "pippo");
    log.debug("forzo i consuntivi da " + wpInizio + " a " +  wpFine);
    this.wpInizio = wpInizio;
    this.wpFine = wpFine;
    this.dataInizio = dataInizio;
    this.dataFine = dataFine;
    this.numThread = num3d;
    this.m_con = m_con;
  }

  public void start(){
    try{
      forzaAssegnamentiPerActual();
    }
    catch(Exception se){
      se.printStackTrace();
      log.error(se);
    }
  }

mentre infine nel metodo forzaAssegnamentiPerActual() ci sono le varie operazioni (fa una query, per ogni record di questa query fa una seconda query di insert in un'altra tabella.

Il problema mi sembra questo:
quando faccio

tfc1.start();

il controllo torna alla classe princiapale o finchè non ha terminato il metodo forzaAssegnamentiPerActual() richiamato nello start del thread non continua?
Come faccio a fargli capire che mentre che sta eseguendo il metodo forzaAssegnamentiPerActual per il thread1 nel frattemop può far partier anche il secondo 3d?

[LeleFT]

Puoi postare almeno la firma del metodo forzaAssegnamentiPerActual()?


Ciao.

[Pablob]

    
  public ThreadForzaConsuntivi(ThreadGroup tg, Connection m_con, 
                               int wpInizio, int wpFine, 
                               String dataInizio, String dataFine, 
                               int num3d) {
    super(tg, "pippo");
    log.debug("forzo i consuntivi da " + wpInizio + " a " +  wpFine);
    this.wpInizio = wpInizio;
    this.wpFine = wpFine;
    this.dataInizio = dataInizio;
    this.dataFine = dataFine;
    this.numThread = num3d;
    this.m_con = m_con;
  }

  public void run(){
    try{
      forzaAssegnamentiPerActual();
    }
    catch(Exception se){
      se.printStackTrace();
      log.error(se);
    }
  }

Non devi sovrascrivere il metodo start(), ma il metodo run() del Thread.
Questo, in breve. Nel dettaglio, consiglio di guardarti un tutorial sulla gestione dei Thread in Java...

[prozac76]

Forse potresti provare a sincronizzarli!
Puoi creare una classe che ha metodi con i quali interagisci col db..metodi tutti syncronized...e poi avvii i treads in modo da non generare collisioni e renderli indipendenti!

[LeleFT]

Originariamente inviato da Pablob

    
public void run(){

Non me n'ero nemmeno accorto!!!


Ciao.

[Pablob]

Originariamente inviato da LeleFT
Non me n'ero nemmeno accorto!!!


Ciao.

cose che capitano...