Múltiples consultas de bases de datos en paralelo, para una sola solicitud de cliente

Question

Para completar ciertas solicitudes del usuario, en mi aplicación, estoy emitiendo múltiples consultas de bases de datos desde un solo método, pero actualmente se están ejecutando secuencialmente & por lo que la aplicación está bloqueada hasta el momento en que ha recibido la respuesta/datos para la consulta anterior, luego proceder a la siguiente consulta. Esto no es algo que me gusta mucho. Me gustaría enviar consultas paralelas.

También después de realizar consultas me gustaría hacer otro trabajo (en lugar de estar bloqueado hasta respuesta de consultas anteriores) & para obtener la respuesta para cada consulta Me gustaría ejecutar un bloque de código específico para los datos de cada consulta. ¿Cuál es la manera de hacer esto?

Editar: Mi API DB proporciona la agrupación de conexiones.

---

estoy sólo un poco familiarizados con múltiples hilos de Java.

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

Answer 1

Aquí es un enfoque muy trivial/limitada:

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 
} 

Este es un enfoque simple, pero muchos otros son posibles (por ejemplo, conjunto de hilos a través de ejecutores de tareas Java concurrencia, ejecutores de tareas primavera, etc.) .

Answer 2

Usted debe entender antes de empezar a hacer esto

1. Para beneficiarse de concurrencia, es necesario tener múltiples conexiones db. La mejor manera de resolver esto es crear un grupo db.

2. Necesita crear una clase ejecutable/invocable para ejecutar una declaración de db. Necesitará armar algún sistema de mensajería para alertar a los oyentes cuando su consulta haya completado

3. Entienda que cuando está enviando varias solicitudes al mismo tiempo, todas las apuestas están desactivadas y se completará primero, y que hay puede haber conflictos entre declaraciones que desestabilicen su aplicación.

Answer 3

Tengo la tarea/problema similar. Para obtener el resultado de compilación completo, debo enviar algunas solicitudes para unos pocos servicios diferentes (pocos en REST, pocos en Thrift), para disminuir la latencia necesito enviarlos en paralelo. Mi idea es usar java.util.concurrent.Future, crear un administrador de agregación simple, que cree muchas solicitudes juntas y se aguarde la última respuesta recuperada y devuelva todos los datos necesarios. En una solución más avanzada, este administrador puede hacer/combinar el resultado final durante otras consultas, pero esta solución puede no ser segura para subprocesos.