[JAVA]Come blocco un thread?

[MEMon]

Ho un thread in stato di runnable, devo fare in modo però che dopo aver eseguito il codice del metodo run() si fermi fino a quando non glielo dico io, cioè vorrei avere la possibilità di sospendere il thread e risvegliarlo quando mi pare.
Quello che potrebbe fare al caso mio è yeld() ma non va bene perchè non ho altri thread a cui passare il comando...non esiste un modo per bloccare un thread?

Ovviamente questo non va bene:

Thread t =new Thread(){
       public void run(){
              while(true){
                     if(ok){
                           ...esegui codice...
                     }
               }
       }
};

Per il semplice motivo che mi spreca troppe risorse e poi è anche brutto come metodo... Ma quello che voglio ottenere è proprio quello.

[MEMon]

Ho fatto del casino forse, allora vorrei fare una cosa del genere:

Thread t =new Thread(){
       public void run(){
               ...esegui codice...
               sospendi();  //sospende il thread finchè non viene risvegliato
       }
};

public void risveglia(){
      ...codice...  //fa rieseguire il metodo run()
}

E' fattibile?

[The3DProgrammer]

Originariamente inviato da MEMon

Ho un thread in stato di runnable, devo fare in modo però che dopo aver eseguito il codice del metodo run() si fermi fino a quando non glielo dico io, cioè vorrei avere la possibilità di sospendere il thread e risvegliarlo quando mi pare.
Quello che potrebbe fare al caso mio è yeld() ma non va bene perchè non ho altri thread a cui passare il comando...non esiste un modo per bloccare un thread?

Ovviamente questo non va bene:

Thread t =new Thread(){
       public void run(){
              while(true){
                     if(ok){
                           ...esegui codice...
                     }
               }
       }
};

Per il semplice motivo che mi spreca troppe risorse e poi è anche brutto come metodo... Ma quello che voglio ottenere è proprio quello.

Thread t =new Thread(){
       private Object monitor=new Object();
       private bool suspended=false;


      public void suspend(){ suspended = true;}
      public void notify(){ suspended = false; monitor.notify();}

    

       public void run(){
              while(true){
                     if(suspended){
                             try{
                               monitor.wait();
                             }catch(InterruptedException ecxeption){
                             ...
                             }
                      }
                      ...esegui codice...
                     
               }
       }
};

ciao

[MEMon]

Ti ringrazio, non sapevo della possibilità di usare un oggetto in questo modo!
Grazie!

[MEMon]

Mi solleva l'eccezzione "current thread not owner", per quale motivo?

[The3DProgrammer]

Originariamente inviato da MEMon

Mi solleva l'eccezzione "current thread not owner", per quale motivo?

spe su quale riga?


sono un po intontito (appena svegliato) quindi sicuramente ho scordato qualkosa

[MEMon]

su monitor.wait()

[The3DProgrammer]

ma ke kakkio ho scritto

aspe che ti posto la versione corretta....

[MEMon]

no problem!

[MEMon]

Ho trovato questa che fa uso di syncronized:

    // Create and start the thread
    MyThread thread = new MyThread();
    thread.start();
    
    while (true) {
        // Do work
    
        // Pause the thread
        synchronized (thread) {
            thread.pleaseWait = true;
        }
    
        // Do work
    
        // Resume the thread
        synchronized (thread) {
            thread.pleaseWait = false;
            thread.notify();
        }
    
        // Do work
    }
    
    class MyThread extends Thread {
        boolean pleaseWait = false;
    
        // This method is called when the thread runs
        public void run() {
            while (true) {
                // Do work
    
                // Check if should wait
                synchronized (this) {
                    while (pleaseWait) {
                        try {
                            wait();
                        } catch (Exception e) {
                        }
                    }
                }
    
                // Do work
            }
        }
    }

[The3DProgrammer]

infatti
devi semplicemente mettere le chiamate a wait() e notify() tra 2 blokki synchronized(monitor) altrimenti come diventa il thread owner del monitor? Quella postata da te è praticamente come la mia, solo che usa come oggetto monitor il thread stesso. Personalmente nn mi piace come scelta, anche se perfettamente leggittima (se espliciti l'oggetto monitor diventa + chiaro IMHO)


ciao e scusa, la sonnolenza fa brutti skerzi

[The3DProgrammer]

Thread t =new Thread(){
       private Object monitor=new Object();
       private bool suspended=false;


      public void suspend(){ suspended = true;}
      public void notify(){ 

           suspended = false; 
            synchronized(monitor){
                monitor.notify();
             }
       }

    

       public void run(){
              while(true){
                     if(suspended){
                             try{
                               synchronized(monitor){
                                    monitor.wait();
                                }
                             }catch(InterruptedException ecxeption){
                             ...
                             }
                      }
                      ...esegui codice...
                     
               }
       }
};

[MEMon]

Ok grazie mille!

[PGI-Bis]

Quel suspended deve essere volatile o il suo valore deve essere mutato all'interno di un blocco sincronizzato altrimenti non c'è garanzia che il valore di suspended letto dal Thread in attesa al momento del risveglio sia l'ultimo valore immesso da un Thread concorrente.

[cisc]

Thread t =new Thread(){
       private Lock monitor=new ReentrantLock();

       private boolean suspended=false;

       private Condition wait = monitor.newCondition();


      public void suspend(){ 
          monitor.lock();
          try {       
              suspended = true;
          } finally {
              monitor.unlock();
          }    
      }
      public void notify(){ 
          monitor.lock();
          try { 
                suspended = false; 
                wait.signal();
          } finally {
              monitor.unlock();
          }   
       }

    

       public void run(){
              while(true){
                          monitor.lock();
                          try { 
                                while (suspendend)
                                    wait.await();
                         }catch(InterruptedException ecxeption){
                         ...
                         } finally {
                              monitor.unlock();
                         }   
                  ...esegui codice...
                     
               }
       }
};

P.S: Java 1.5 only

[The3DProgrammer]

Originariamente inviato da PGI-Bis

Quel suspended deve essere volatile o il suo valore deve essere mutato all'interno di un blocco sincronizzato altrimenti non c'è garanzia che il valore di suspended letto dal Thread in attesa al momento del risveglio sia l'ultimo valore immesso da un Thread concorrente.

hai perfettamente ragione. suspended è una variabile a cui si accede in concorrenza, per cui deve essere inserita in un blocco synchronized. In questo caso basta rendere synchronized i metodi suspend e notify (che tra l'altro come nomi di metodi nn vanno bene xkè significherebbe overriding di metodi final, ero proprio intronato ieri ) ed inserire l'accesso in run alla variabile suspended in un blocco synchronized(this).

ciauz

[MEMon]

Originariamente inviato da The3DProgrammer

...ed inserire l'accesso in run alla variabile suspended in un blocco synchronized(this).

ciauz

Ovvero?

[MEMon]

Ho fatto così:

synchronized(controllo){
	synchronized(this){
		if(sospeso){
			try{
				controllo.wait();
			}
				catch(InterruptedException e){System.out.println(e);}
			}
		}
	}

Ma ora non funziona più, il thread non si risveglia, come devo fare?

[The3DProgrammer]

Originariamente inviato da MEMon

Ho fatto così:

synchronized(controllo){
	synchronized(this){
		if(sospeso){
			try{
				controllo.wait();
			}
				catch(InterruptedException e){System.out.println(e);}
			}
		}
	}

Ma ora non funziona più, il thread non si risveglia, come devo fare?

così nn si sveglia + xkè il thread, entrando in wait, rilascia la ownership sul monitor controllo ma nn sull'altro (this) cosa che provoca l'impossibilità di accedere a controllo.notify() da parte degli altri thread concorrenti. Dovresti fare una cosa del genere:

[code]

while(true){
    boolean mustWait=false;

    synchronized(this){
        mustWait=sospeso;
    }

     if(mustWait){
        synchronized(controllo){      
              try{
                   controllo.wait();
	}
	catch(InterruptedException e){System.out.println(e);}
        }
    }
}

a questo punto xò questa implementazione comincia a nn 'piacermi + (1 solo monitor è + ke sufficiente a realizzare una cosa del genere, complicare il codice con troppe strutture di sincronizzazione in ambito multithread è sempre male) per cui potresti usare l'implementazione che hai trovato sul web (che usa l'oggetto thread stesso come monitor), o quella ke ha postato cisc

ciauz

[The3DProgrammer]

ora che guardo bene anche quella ke hai postato xò elimina quegli abberranti

synchronized(thread){
thread.pleaseWait=x;
}

e metti 2 metodi synchronized, ma soprattutto metti pleaseWait privata

ciau