Richieste multiple di database in parallelo, per una singola richiesta client

Question

Per completare determinate richieste dall'utente, nella mia applicazione, sto emettendo più query DB da un singolo metodo, ma sono attualmente eseguite sequenzialmente & quindi l'applicazione è bloccata fino al momento in cui ha ricevuto la risposta/i dati per la query precedente, quindi passare alla query successiva. Questo non è qualcosa che mi piace molto. Vorrei inviare query parallele.

anche dopo l'emissione query Vorrei fare qualche altro lavoro, (invece di essere bloccati fino risposta query precedente) & su come ottenere la risposta per ogni query vorrei eseguire un blocco di codice specifico per i dati di ogni query. Qual è il modo di fare questo?

Modifica: la mia API DB fornisce il pool di connessioni.

---

Sono solo un po ' familiarità con Java multithreading.

Using:- 
------ 
Java 1.6 
Cassandra 1.1 Database with Hector 

Answer 1

Ecco un banale/approccio limitato:

final Connection conn = ...; 
final Object[] result = new Object[1]; 
Thread t1 = new Thread(new Runnable() { 
    public void run() { 
     Object results = conn.executeQuery(); 
     result[0] = results; 
    } 
}); 
t1.setName("DBQueryWorker"); 
t1.start(); 
// do other work 
while (t1.isAlive()) { 
    // wait on thread one 
} 

Questo è un approccio semplice, ma molti altri sono possibili (ad esempio, messa in comune filo tramite Java Concorrenza esecutori di attività, esecutori compito Primavera, ecc) .

Answer 2

Si dovrebbe capire prima di iniziare a fare questo

1. Per beneficiare di concorrenza, è necessario disporre di più connessioni db. Il modo migliore per risolvere questo è creare un pool db.

2. È necessario creare una classe eseguibile/richiamabile per l'esecuzione di una dichiarazione db. Dovrai mettere insieme un sistema di messaggistica per avvisare gli ascoltatori quando la query è completata

3. Capire che quando si inviano più richieste allo stesso tempo, tutte le scommesse sono spente su quale verrà completata per prima, e che lì potrebbero essere conflitti tra dichiarazioni che destabilizzano la tua app.

Answer 3

Ho il compito/problema simile. Per i risultati di compilazione completi, ho bisogno di inviare poche richieste per pochi servizi diversi (pochi su REST, pochi su Thrift), per ridurre la latenza ho bisogno di inviarlo in parallelo. La mia idea è usare java.util.concurrent.Future, creare un semplice gestore di aggregazioni, che crea molte richieste insieme e aspetterà l'ultima risposta recuperata e restituirà tutti i dati necessari. In una soluzione più avanzata questo gestore può creare/combinare il risultato finale durante altre query, ma questa soluzione può non essere thread-safe.