Multi: Threading - È questo l'approccio giusto?

Question

Esperti -

Ho bisogno di un consiglio nel seguente scenario.

Ho un file di configurazione con un elenco di attività. Ogni attività può avere zero, una o più dipendenze. Volevo eseguire queste attività in parallelo [in questo momento vengono eseguite in sequenza]

L'idea è di avere un programma principale per leggere il file di configurazione e caricare tutte le attività. Leggi le singole attività e assegnale a un esecutore [callable] che eseguirà l'attività e restituirà i risultati in un futuro. Quando l'attività viene inoltrata all'esecutore (thread), controllerà che le sue dipendenze finiscano prima ed esegua la propria attività.

È questo l'approccio giusto? Esistono altri approcci migliori che utilizzano le funzionalità di java 1.5?

Answer 1

Suoni bene, ma attenzione di Thread starvation deadlock. Fondamentalmente, non usare un pool di thread limitato.

Ecco un esempio che illustra questo problema.
http://www.javaconcurrencyinpractice.com/listings/ThreadDeadlock.java

Inoltre, se si dispone per es. una connessione DB in pool, potresti incontrare anche dei problemi. 10 thread possono bloccare, mantenendo tutta la connessione in pool, in attesa dell'11 ° thread che non può acquisire l'11a connessione in pool perché non è più disponibile ..

Answer 2

Quello che hai descritto è l'approccio Java5/6.

Assicurati solo che le tue attività/Callables non siano condivise/non condividano lo stato.

Answer 3

Considerare l'utilizzo di ValueFuture (da guava) per comunicare tra le attività. Aggiungi un listener a ogni ValueFuture che invia una nuova attività a ExecutorService solo quando tutti i suoi input sono disponibili. In questo modo non avrai mai un blocco di thread in qualche modo attraverso un'attività in attesa che finisca un'altra attività.

Answer 4

attività del database, l'archiviazione e la regola di elaborazione sono usi perfetti per Ant (o anche Maven)

Non reinventare questo. Basta usare Ant.

Scrivi attività ant per ogni attività. Definire le dipendenze in XML, usando le regole di dipendenza di Ant.

Trasforma formica libera per eseguire le attività in base alle dipendenze. È possibile iniziare con Ant Task "eseguibili" (http://ant.apache.org/manual/tasksoverview.html#exec) anziché definire la propria sottoclasse di Attività.

Ant comprende attività parallele. Non è necessario fare altro che dichiarare le attività come parallele. http://ant.apache.org/manual/Tasks/parallel.html

Non inventare alcun nuovo software per questo. Usa Ant.

Answer 5

In realtà, si do si desidera il multi-threading quando il costo di avvio di più processi è costoso.

Che, francamente, è quasi tutto ciò che gira una copia della JVM.

Per rispondere all'OP, ANT è in grado di eseguire attività in parallelo ma NON in parallelo. Quindi, anche se si dispone di un file build.xml che si desidera modificare per l'esecuzione parallela, è necessario eseguire una riscrittura maggiore. (Penso che sia stata una decisione progettuale piuttosto strana presa dagli sviluppatori ANT dal momento che hai già il tuo grafico di dipendenza descritto dagli obiettivi stessi.)