¿Cómo se utiliza el multiprocesamiento para abordar problemas embarazosamente paralelos ? Los problemas vergonzosamente paralelos suelen constar de tres partes básicas: Leer datos de entrada (de un archivo, base de datos, conexión tcp, etc.). Ejecute cálculos sobre los datos de entrada, donde...
Estoy tratando de codificar una solución en la que un solo subproceso produce tareas intensivas de E / S que se pueden realizar en paralelo. Cada tarea tiene datos importantes en memoria. Por eso quiero poder limitar la cantidad de tareas pendientes en un momento. Si creo ThreadPoolExecutor...
El siguiente código da un error de compilación que dice 'marcha inesperada': x := go doSomething(arg) func doSomething(arg int) int{ ... return my_int_value } Lo sé, puedo recuperar el valor de retorno si llamo a la función normalmente, sin usar goroutine. O puedo usar canales, etc. Mi...
¿Hay alguna forma de protegerse contra modificaciones simultáneas de la misma entrada de la base de datos por parte de dos o más usuarios? Sería aceptable mostrar un mensaje de error al usuario que realiza la segunda operación de confirmación / guardado, pero los datos no deben sobrescribirse...
¿Por qué no hay palabras clave para sincronización / simultaneidad? Hasta ahora, mi investigación me brinda una solución, envuelve algunas clases de alto nivel y las usa para manejar la concurrencia. Dado un proyecto en Kotlin puro, ¿qué se debe hacer si se necesita un componente pequeño...
¿Cómo borrar el ConcurrentBag? no tiene ningún método como Clearo RemoveAll...
¿Solo devolverá falso si el diccionario no contiene un valor para la clave dada o también devolverá falso debido a las condiciones de carrera del hilo, como si otro hilo agrega / actualiza algo? Pregunta en código: ConcurrentDictionary<int, string> cd = new ConcurrentDictionary<int,...
El modelo de programación dirigido por eventos de node.js hace que sea algo complicado coordinar el flujo del programa. La ejecución secuencial simple se convierte en devoluciones de llamada anidadas, lo cual es bastante fácil (aunque un poco complicado de escribir). Pero, ¿qué hay de la...
Mientras intentaba entender cómo SubmissionPublisher( código fuente en Java SE 10, OpenJDK | docs ), una nueva clase agregada a Java SE en la versión 9, se implementó, me topé con algunas llamadas a la API VarHandleque no conocía anteriormente: fullFence` acquireFence` releaseFence, loadLoadFencey...
Necesito algún tipo de servicio que ejecute algunas tareas simultáneamente y en un intervalo de 1 segundo durante 1 minuto. Si una de las tareas falla, quiero detener el servicio y cada tarea que se ejecutó con algún tipo de indicador de que algo salió mal, de lo contrario, si después de un minuto...
¿Las corutinas de Kotlin ofrecen garantías de "sucede antes"? Por ejemplo, ¿existe una garantía de "sucede antes" entre la escritura mutableVary la posterior lectura en (potencialmente) otro hilo en este caso: suspend fun doSomething() { var mutableVar = 0 withContext(Dispatchers.IO) {...
push_back , begin , end se describen como concurrentes seguros en https://docs.microsoft.com/en-us/cpp/parallel/concrt/reference/concurrent-vector-class?view=vs-2019#push_back Sin embargo, el siguiente código está afirmando. Probablemente porque el elemento se agrega pero aún no se ha...
He escuchado y leído varios artículos, charlas y preguntas sobre el stackoverflow std::atomic, y me gustaría asegurarme de haberlo entendido bien. Debido a que todavía estoy un poco confundido con la línea de caché, la visibilidad de las escrituras se debe a posibles retrasos en los protocolos de...
Un patrón que he encontrado varias veces ahora es uno en el que se debe verificar una lista de valores mapeando alguna prueba sobre él y ver si alguno o todos los elementos pasaron. La solución típica es usar los convenientes elementos integrados ally any. El problema es que estos se evalúan en...
Supongamos que tengo un campo al que se accede simultáneamente y se lee muchas veces y rara vez se escribe. public Object myRef = new Object(); Digamos que un subproceso T1 establecerá myRef en otro valor, una vez por minuto, mientras que otros subprocesos leerán myRef miles de millones de veces...
Quiero escribir un programa cuyo hilo principal bifurca un nuevo hilo para el cálculo y espera a que termine por un período de tiempo. Si el hilo secundario no termina en un tiempo dado, se agota el tiempo de espera y se elimina. Tengo el siguiente código para esto. import Control.Concurrent fibs...