Torna indietro   Hardware Upgrade Forum > Software > Programmazione

Samsung Galaxy S25 Edge: il top di gamma ultrasottile e leggerissimo. La recensione
Samsung Galaxy S25 Edge: il top di gamma ultrasottile e leggerissimo. La recensione
Abbiamo provato il nuovo Galaxy S25 Edge, uno smartphone unico per il suo spessore di soli 5,8 mm e un peso super piuma. Parliamo di un device che ha pro e contro, ma sicuramente si differenzia dalla massa per la sua portabilità, ma non senza qualche compromesso. Ecco la nostra prova completa.
HP Elitebook Ultra G1i 14 è il notebook compatto, potente e robusto
HP Elitebook Ultra G1i 14 è il notebook compatto, potente e robusto
Pensato per il professionista sempre in movimento, HP Elitebook Ultra G1i 14 abbina una piattaforma Intel Core Ultra 7 ad una costruzione robusta, riuscendo a mantenere un peso contenuto e una facile trasportabilità. Ottime prestazioni per gli ambiti di produttività personale con un'autonomia lontano dalla presa di corrente che permette di lavorare per tutta la giornata
Microsoft Surface Pro 12 è il 2 in 1 più compatto e silenzioso
Microsoft Surface Pro 12 è il 2 in 1 più compatto e silenzioso
Basato su piattaforma Qualcomm Snapdragon X Plus a 8 core, il nuovo Microsoft Surface Pro 12 è un notebook 2 in 1 molto compatto che punta sulla facilità di trasporto, sulla flessibilità d'uso nelle differenti configurazioni, sul funzionamento senza ventola e sull'ampia autonomia lontano dalla presa di corrente
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


Samsung Galaxy S25 Edge: il top di gamma ultrasottile e leggerissimo. La recensione Samsung Galaxy S25 Edge: il top di gamma ultraso...
HP Elitebook Ultra G1i 14 è il notebook compatto, potente e robusto HP Elitebook Ultra G1i 14 è il notebook c...
Microsoft Surface Pro 12 è il 2 in 1 più compatto e silenzioso Microsoft Surface Pro 12 è il 2 in 1 pi&u...
Recensione REDMAGIC Astra Gaming Tablet: che spettacolo di tablet! Recensione REDMAGIC Astra Gaming Tablet: che spe...
Dopo un mese, e 50 foto, cosa abbiamo capito della nuova Nintendo Switch 2 Dopo un mese, e 50 foto, cosa abbiamo capito del...
Alchimia? No, scienza: ecco come produrr...
Il CISPE chiede di annullare l'acquisizi...
La Now Bar supporterà il doppio d...
Vecchi Bitcoin, guadagno mostruoso: bale...
Nel 2018 Samsung snobbò NVIDIA: u...
Provare i vestiti senza mai uscire di ca...
SanDisk High Bandwidth Flash (HBF): un c...
Panasonic presenta Aquarea DHW, pompa di...
Il bracciale Meta leggerà i gesti...
iOS e Android sotto attacco: per l'antit...
A Verona dopo i monopattini ecco le e-bi...
Itch.io come Steam: al bando i giochi pe...
Digitalizzazione, identità e AI: ...
Kindle Colorsoft: arriva la versione da ...
Electra ottiene altri 433 milioni di eur...
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: 20:21.


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