Resultados de la búsqueda a petición "concurrency"

2 la respuesta

¿Cómo puede CopyOnWriteArrayList ser seguro para subprocesos?

He echado un vistazo aCódigo fuente de ...

2 la respuesta

casos de mal uso de scala.concurrent.blocking?

Con referencia al tercer punto enesta [https://stackoverflow.com/a/19682155/383053]respuesta aceptada, ¿hay algún caso en el que sería inútil o malo usarblocking para un cálculo de larga duración, ya sea con CPU o IO, que se ejecuta 'dentro' de ...

3 la respuesta

Concurrencia de Java: ¿Volátil vs final en variables "en cascada"?

es final Map<Integer,Map<String,Integer>> status = new ConcurrentHashMap<Integer, Map<String,Integer>>(); Map<Integer,Map<String,Integer>> statusInner = new ConcurrentHashMap<Integer, Map<String,Integer>>(); status.put(key,statusInner); lo mismo ...

10 la respuesta

Java ExecutorService: await Terminación de todas las tareas creadas recursivamente

Yo uso unExecutorService para ejecutar una tarea Esta tarea puede crear recursivamente otras tareas que se envían a la mismaExecutorService y esas tareas secundarias también pueden hacer eso. Ahora tengo el problema de que quiero esperar hasta ...

2 la respuesta

¿Se ejecutan los futuros en un solo hilo? (Scala)

Usando el contexto de ejecución implícito predeterminado en Scala, ¿se calculará cada nuevo futuro en un solo hilo dedicado o el cálculo se dividirá y distribuirá a múltiples hilos en el grupo de hilos? No sé si esto ayuda, el trasfondo de esta ...

1 la respuesta

¿Puedo asegurarme de que Haskell realice una IO atómica?

Tengo dos hilos en Haskell que realizan IO. (Solo imprimen). Algo como lo siguiente: thread1 :: IO () thread1 = putStrLn "One" thread2 :: IO () thread2 = putStrLn "Two"Actualmente estoy obteniendo resultados como los siguientes: OnTwoe ...

1 la respuesta

Java, divida el trabajo entrante de manera uniforme a través de hashing en entornos multiproceso

He implementado un código Java para ejecutar tareas entrantes (comoRunnable) con n subprocesos basados en su módulo hashCodenThreads. El trabajo debe extenderse, idealmente, de manera uniforme, entre esos hilos. Específicamente, ...

1 la respuesta

Slick 3.0-RC3 falla con java.util.concurrent.RejectedExecutionException

Estoy tratando de familiarizarme con Slick 3.0 y Futures (usando Scala 2.11.6). Yo uso código simple basado enEjemplo de patrón de pastel Multi-DB de Slick [http://typesafe.com/activator/template/slick-multidb-3.0]. ¿Por qué el siguiente código ...

2 la respuesta

¿Puedo `__ restringir__ esto` de alguna manera?

He estado mirandoCharla de Mike Acton sobre diseño orientado a datos en C ++ [https://www.youtube.com/watch?v=rX0ItVEVjHc]en CppCon 2014, y él da este ejemplo: int Foo::Bar(int count) { int value = 0; for (int i = 0; i < count; i++) { ...

4 la respuesta

¿Cómo implementar Future como aplicativo en Scala?

Supongamos que necesito ejecutar dos cálculos simultáneos, esperar a los dos y luego combinar sus resultados. Más específicamente, necesito correrf1: X1 => Y1 yf2: X2 => Y2 simultáneamente y luego llamarf: (Y1, Y2) => Y para finalmente obtener un ...