0

Estoy buscando una forma para poder ejecutar en paralelo las siguientes dos lineas de código con hilos. He visto algunas opciones, pero todas pasan por crear una clase Thread, pero no puedo crear la clase en este caso. No sé muy bien como puedo crear los dos hilos y que se ejecuten en paralelo:

list.forEach(reviewsList -> {
    reviewWriter.persistReviews(reviewsList, activeTable);
});
saveInCoherence();

private void saveInCoherence() {
    reviewsMap.forEach((keyMap, reviewList) -> {
        ...
    }
}

A modo funcional, lo que hará esto es una parte ir a Oracle y hará inserts y la otra parte irá a una caché y cacheará lo mismo. El tema es que el proceso tarda demasiado y por eso me gustaría meter hilos para que ambos procesos vayan en paralelo.

5
  • Implementa Runnable y su metodo run -> carballude.es/blog/2010/03/01/478
    – JDev
    Commented el 10 oct. 2018 a las 14:43
  • No puedo implementar una clase nueva que herede de Thread o Runnable... Tendria que ser algo, de hilos que engloben cada una de esas lineas.
    – hector s.
    Commented el 10 oct. 2018 a las 14:46
  • Pues me temo que imposible entonces.
    – JDev
    Commented el 10 oct. 2018 a las 14:48
  • ¿Por qué no puedes usar Thread?
    – SJuan76
    Commented el 10 oct. 2018 a las 15:46
  • Si puedo usar Thread, lo que no puedo hacer es crear una clase que herede de Thread, porque tendría que mover parte del código a la clase y funcionalmente afectaría bastante de lo que hay que cambiar en la implementación
    – hector s.
    Commented el 10 oct. 2018 a las 18:21

1 respuesta 1

0

Dices que no puedes crear nuevas clases, claramente se hace mas complicado, pero no imposible, cuando tengo que ejecutar algo en Threads, creo un Runnable

    ThreadPoolExecutor executor = new ScheduledThreadPoolExecutor(1);
    Runnable runnable = new Runnable() {

        @Override
        public void run() {

            try {
                functionToCall();
            } catch (Exception e) {
                LOG.error("Error to run task", e);
            }
        }
    };
    executor.execute(runnable);

Espero te sirva para lo que necesitas.

Tu Respuesta

By clicking “Publica tu respuesta”, you agree to our terms of service and acknowledge you have read our privacy policy.

¿No es la respuesta que buscas? Examina otras preguntas con la etiqueta o formula tu propia pregunta.