Mehrere Datenbankabfragen parallel für eine einzige Clientanforderung

Question

Um bestimmte Anforderungen des Benutzers zu erfüllen, erstelle ich in meiner Anwendung mehrere DB-Abfragen von einer einzigen Methode, aber sie werden derzeit sequenziell ausgeführt & daher wird die Anwendung blockiert bis zu dem Zeitpunkt, zu dem die Antwort/Daten für die vorherige Abfrage empfangen wurden, und dann zur nächsten Abfrage weitergegangen ist. Das mag ich nicht besonders. Ich möchte parallele Abfragen ausgeben.

Auch nach dem Ausgeben von Abfragen möchte ich einige andere Arbeit tun, (statt bis Antwort der vorherigen Abfragen blockiert) & auf die Antwort für jede Abfrage Ich möchte einen Code-Block für jede Abfrage Daten ausführen möchten. Wie soll man das machen?

Bearbeiten: Meine DB-API bietet Verbindungspooling.

---

Ich bin nur ein wenig vertraut mit Java Multithreading.

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

Answer 1

Hier ist ein sehr trivial/limited Ansatz:

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 
} 

Dies ist ein einfacher Ansatz, aber viele andere sind möglich (zB Thread-Pooling über Java Concurrency Aufgabe Testamentsvollstrecker, Frühling Aufgabe Testamentsvollstrecker, usw.) .

Answer 2

Sie verstehen sollten, bevor Sie dieses

1. tun beginnen von Gleichzeitigkeit zu profitieren, müssen Sie mehrere db Verbindungen haben. Der beste Weg, dies zu lösen, ist ein Datenbankpool zu erstellen.

2. Sie müssen eine runnable/callable-Klasse zum Ausführen einer db-Anweisung erstellen. Sie müssen ein Messaging-System zusammenstellen, um die Zuhörer darauf aufmerksam zu machen, wenn Ihre Anfrage abgeschlossen ist. Wenn Sie mehrere Anfragen gleichzeitig senden, sind alle Wetten deaktiviert, welche zuerst abgeschlossen werden sollen und welche nicht können Konflikte zwischen Aussagen sein, die Ihre App destabilisieren.

Answer 3

Ich habe die ähnliche Aufgabe/Problem. Für ein vollständiges Build-Ergebnis muss ich wenige Anfragen für wenige verschiedene Dienste senden (wenige für REST, wenige für Thrift), um die Latenz zu verringern, muss ich sie parallel senden. Meine Idee ist es, java.util.concurrent.Future zu verwenden, einen einfachen Aggregationsmanager zu erstellen, der viele Anfragen zusammenstellt und die zuletzt abgerufene Antwort wartet und alle benötigten Daten zurückgibt. In einer fortgeschritteneren Lösung kann dieser Manager das Endergebnis während anderer Abfragen erstellen/kombinieren, aber diese Lösung kann nicht Thread-sicher sein.