Torna indietro   Hardware Upgrade Forum > Software > Programmazione

Ryzen Threadripper 9980X e 9970X alla prova: AMD Zen 5 al massimo livello
Ryzen Threadripper 9980X e 9970X alla prova: AMD Zen 5 al massimo livello
AMD ha aggiornato l'offerta di CPU HEDT con i Ryzen Threadripper 9000 basati su architettura Zen 5. In questo articolo vediamo come si comportano i modelli con 64 e 32 core 9980X e 9970X. Venduti allo stesso prezzo dei predecessori e compatibili con il medesimo socket, le nuove proposte si candidano a essere ottimi compagni per chi è in cerca di potenza dei calcolo e tante linee PCI Express per workstation grafiche e destinate all'AI.
Acer TravelMate P4 14: tanta sostanza per l'utente aziendale
Acer TravelMate P4 14: tanta sostanza per l'utente aziendale
Forte di soluzioni tecniche specifiche, il notebook Acer TravelMate P4 14 abbina dimensioni compatte e buona robustezza per rispondere alle necessità specifiche degli utenti aziendali. La piattaforma AMD Ryzen 7 Pro assicura prestazioni elevate con i tipici ambiti di produttività personale e sul lavoro, mantenendo un'elevata autonomia.
Hisense M2 Pro: dove lo metti, sta. Mini proiettore laser 4K per il cinema ovunque
Hisense M2 Pro: dove lo metti, sta. Mini proiettore laser 4K per il cinema ovunque
Dal salotto al giardino, il nuovo proiettore laser di Hisense promette esperienze cinematografiche in qualsiasi contesto: qualità d’immagine, semplicità d’uso, versatilità e prezzo competitivo il suo poker d'assi
Tutti gli articoli Tutte le news

Vai al Forum
Rispondi
 
Strumenti
Old 05-03-2010, 13:37   #1
banryu79
Senior Member
 
L'Avatar di banryu79
 
Iscritto dal: Oct 2007
Città: Padova
Messaggi: 4131
[JAVA][Concurrency API]Supportare la cancellazione di un task

Salve,
ho la neccessità di definire dei task che vengono eseguiti in parallelo tramite una fixed thread pool:
Codice:
...
ExecutorService fixedPool = Executors.newFixedTrheadPool(N_THREADS);
Questi task sono definiti come implementazioni di Callable:
Codice:
private class SetupTASK implements Callable<OpResult<?>>
{
    private final Session SESSION;

    SetupTASK(Session s) {
            SESSION = s;
    }

    @Override
    public OpResult<?> call() throws Exception {
        ...
    }
}
Creati e passati alla threadPool perchè li esegua in modo asincrono:
Codice:
private void setupSessions() {
    FutureTask<?>[] taskBattery 
            = new FutureTask<?>[POOL.N_THREADS];
        
    // create tasks "battery"
    for (int i=0; i<POOL.N_THREADS; i++) {
        SetupTASK t = new SetupTASK(SESSIONS[i]);
        taskBattery[i] = new FutureTask<OpResult<?>>(t);
    }

    // execute all tasks
    POOL.submitTasks(taskBattery);

    // wait until "battery" execution completes
    OpResult<?> res = null;
    for (int i=0; i<POOL.N_THREADS; i++) {
        try {
            res = (OpResult<?>) taskBattery[i].get();
            ... do something with 'res'
        }
        catch(ExecutionException ignored1) {}
        catch(InterruptedException ignored2) {}
    }
}

...

// on another scope, definition of POOL.submitTasks method:
<E> void submitTasks(FutureTask<E>[] tasks)
{
    for (FutureTask<E> t : tasks)
        fixedPool.submit(t);
}
Dato che devo rendere la batteria di task in esecuzione [taskBattery] "cancellabile" (l'utente vede una progress bar e un bottone "Annulla") pensavo di chiamare il metodo cancel() esposto da ogni FutureTask in taskBattery, con il parametro mayInterruptIfRunning valorizzato a true:
Quote:
cancel

boolean cancel(boolean mayInterruptIfRunning)

Attempts to cancel execution of this task. This attempt will fail if the task has already completed, has already been cancelled, or could not be cancelled for some other reason. If successful, and this task has not started when cancel is called, this task should never run. If the task has already started, then the mayInterruptIfRunning parameter determines whether the thread executing this task should be interrupted in an attempt to stop the task.

After this method returns, subsequent calls to isDone() will always return true. Subsequent calls to isCancelled() will always return true if this method returned true.

Parameters:
mayInterruptIfRunning - true if the thread executing this task should be interrupted; otherwise, in-progress tasks are allowed to complete
Returns:
false if the task could not be cancelled, typically because it has already completed normally; true otherwise
I miei dubbi sono:

In questo caso, perchè la cosa funzioni, devo supportare l'interruzione del thread che esegue il task?

Se sì, è corretto supportarlo chiamando in momenti opportuni Thread.interrupted() sul thread che sta eseguendo il task e se si verifica l'interrupt lanciando una InterruptedException? [esempio di implementazione del metodo call() di un task-tipo]:
Codice:
@Override
public OpResult<?> call() throws Exception {
    OpResult<?> res = new OpResult<Object>();

    checkInterrupt();
    res = SESSION.connect(BASE_SESSION);
    if (res.isError()) {
        return res;
    }

    checkInterrupt();
    res = SESSION.login(BASE_SESSION);
    if (res.isError()) {
        return res;
    }

    String[] dirs = BASE_SESSION.arrayPath();
    for (String dir : dirs) {
        checkInterrupt();
        res = SESSION.changeDir(dir);
        if (res.isError()) {
            return res; // break loop
        }
    }

    return res;
}

private void checkInterrupt() throws InterruptedException {
    if (Thread.interrupted())
        throw new InterruptedException();
}
Esistono delle alternative?
Grazie mille, anche solo per la pazienza di aver letto

P.S.: per via di scelte dell'architettura del progetto SwingWorker non è un'opzione.
__________________

As long as you are basically literate in programming, you should be able to express any logical relationship you understand.
If you don’t understand a logical relationship, you can use the attempt to program it as a means to learn about it.
(Chris Crawford)

Ultima modifica di banryu79 : 05-03-2010 alle 13:47.
banryu79 è offline   Rispondi citando il messaggio o parte di esso
Old 05-03-2010, 15:31   #2
PGI-Bis
Senior Member
 
L'Avatar di PGI-Bis
 
Iscritto dal: Nov 2004
Città: Tra Verona e Mantova
Messaggi: 4553
In sintesi sì. Questo:

Codice:
Callable<Void> task = new Callable<Void>() {

    public Void call() throws Exception {
        while(true) {}
    }
}
E' un compito che non può essere interrotto mentre questo:

Codice:
Callable<Void> task = new Callable<Void>() {

    public Void call() throws Exception {
        while(true) {
            if(Thread.interrupted()) throw new Exception("Lavalachelavaben");
        }
    }
}
E' terminabile.
__________________
Uilliam Scecspir ti fa un baffo? Gioffri Cioser era uno straccione? E allora blogga anche tu, in inglese come me!
PGI-Bis è offline   Rispondi citando il messaggio o parte di esso
Old 05-03-2010, 17:18   #3
banryu79
Senior Member
 
L'Avatar di banryu79
 
Iscritto dal: Oct 2007
Città: Padova
Messaggi: 4131
I miei dubbi erano dati dal fatto che FutureTask implementa un metodo 'cancel' e un metodo 'isCancelled'.

Ricordando gli esempi concernenti l'uso del metodo 'doInBackground' di SwingWorker avevo il dubbio fosse sufficiente, anche per quanto riguarda il metodo 'run' di un Callable, controllare internamente con 'isCancelled' se il task fosse stato annullato da una precedente chiamata su 'cancel'.

Invece non c'entra niente: isCancelled viene chiamato sempre e solo alla fine della computazione del FutureTask e serve solo per sapere a posteriori se il task ha terminato la computazione perchè cancellato oppure no.

Grazie della conferma.
__________________

As long as you are basically literate in programming, you should be able to express any logical relationship you understand.
If you don’t understand a logical relationship, you can use the attempt to program it as a means to learn about it.
(Chris Crawford)
banryu79 è offline   Rispondi citando il messaggio o parte di esso
 Rispondi


Ryzen Threadripper 9980X e 9970X alla prova: AMD Zen 5 al massimo livello Ryzen Threadripper 9980X e 9970X alla prova: AMD...
Acer TravelMate P4 14: tanta sostanza per l'utente aziendale Acer TravelMate P4 14: tanta sostanza per l'uten...
Hisense M2 Pro: dove lo metti, sta. Mini proiettore laser 4K per il cinema ovunque Hisense M2 Pro: dove lo metti, sta. Mini proiett...
Lenovo ThinkPad X1 2-in-1 G10 Aura Edition: il convertibile di classe Lenovo ThinkPad X1 2-in-1 G10 Aura Edition: il c...
Intervista a Stop Killing Games: distruggere videogiochi è come bruciare la musica di Mozart Intervista a Stop Killing Games: distruggere vid...
Xbox: dal prossimo mese verifica dell'id...
Corsair AI Workstation 300: poco pi&ugra...
Addio a Elio Marioli, un pioniere della ...
L'IA sta già diminuendo il potere...
Guida autonoma? Gli ADAS falliscono e in...
Skechers lancia le scarpe per bambini co...
Revolut e Audi F1: un’alleanza rivoluzio...
Gestione attività di Windows 11 d...
Amazon lancia il nuovo videocitofono Bli...
Robot aspirapolvere al top: i nuovi DEEB...
Opera vs Microsoft: la guerra dei browse...
Router e ripetitori FRITZ! in offerta su...
Spotify vola a quota 700 milioni di uten...
Microsoft pronta ad abbandonare il launc...
Windows 11, arriva una feature multimoni...
Chromium
GPU-Z
OCCT
LibreOffice Portable
Opera One Portable
Opera One 106
CCleaner Portable
CCleaner Standard
Cpu-Z
Driver NVIDIA GeForce 546.65 WHQL
SmartFTP
Trillian
Google Chrome Portable
Google Chrome 120
VirtualBox
Tutti gli articoli Tutte le news Tutti i download

Strumenti

Regole
Non Puoi aprire nuove discussioni
Non Puoi rispondere ai messaggi
Non Puoi allegare file
Non Puoi modificare i tuoi messaggi

Il codice vB è On
Le Faccine sono On
Il codice [IMG] è On
Il codice HTML è Off
Vai al Forum


Tutti gli orari sono GMT +1. Ora sono le: 19:13.


Powered by vBulletin® Version 3.6.4
Copyright ©2000 - 2025, Jelsoft Enterprises Ltd.
Served by www3v