Równoległe zapytania do bazy danych dla pojedynczego żądania klienta

Question

Aby wykonać niektóre żądania od użytkownika, w mojej aplikacji wysyłam wiele zapytań DB z jednej metody, ale obecnie są one wykonywane sekwencyjnie &, więc aplikacja jest zablokowana do czasu otrzymania odpowiedzi/danych dla poprzedniego zapytania, a następnie przejścia do następnego zapytania. To nie jest coś, co bardzo lubię. Chciałbym wydawać równoległe zapytania.

także po wydaniu zapytania Chciałbym zrobić jakąś inną pracę (zamiast być zablokowane do poprzedniej odpowiedzi zapytań) & na uzyskanie odpowiedzi dla każdego zapytania chciałbym wykonać blok kodu specyficzne dla danych Każde zapytanie jest. Jak to zrobić?

Edycja: Moje DB API zapewnia łączenie połączeń.

---

jestem tylko trochę zaznajomieni z wielowątkowości Java.

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

Answer 1

Oto bardzo trywialne/ograniczone podejście:

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 
} 

Jest to proste podejście, ale wiele innych możliwości (np grupowania wątek poprzez Java współbieżności wykonawców zadanie, wykonawcy zadania Wiosna, etc) są .

Answer 2

Należy zrozumieć, przed rozpoczęciem wykonywania tej

1. Aby skorzystać z współbieżności, trzeba mieć wiele połączeń DB. Najlepszym sposobem rozwiązania tego problemu jest utworzenie puli db.

2. Musisz utworzyć klasę runnable/wpłacone do wykonywania instrukcji dB. Musisz skonfigurować system komunikacyjny, aby powiadomić słuchaczy, kiedy zapytanie zakończyło się:

3. Zrozum, że przy wysyłaniu wielu zgłoszeń w tym samym czasie, wszystkie zakłady są wyłączone, co zostanie zakończone jako pierwsze i że mogą być konflikty między oświadczeniami, które destabilizują twoją aplikację.

Answer 3

Mam podobne zadanie/problem. Aby uzyskać pełny wynik kompilacji, muszę wysłać kilka żądań dla kilku różnych usług (kilka na REST, kilka na Thrift), dla zmniejszenia opóźnienia muszę wysłać to równolegle. Moim pomysłem jest użycie java.util.concurrent.Future, utworzenie prostego menedżera agregacji, który tworzy wiele żądań razem i będzie czekać ostatnie pobrane odpowiedzi i zwróci wszystkie potrzebne dane. W bardziej zaawansowanym rozwiązaniu ten menedżer może tworzyć/łączyć wynik końcowy podczas innych zapytań, ale to rozwiązanie może nie być bezpieczne dla wątków.