Lo que busco es una forma compatible de configurar el uso de un grupo de subprocesos o no. Idealmente, el resto del código no debería verse afectado en absoluto. Podría usar un grupo de subprocesos con 1 subproceso, pero eso no es exactamente lo que quiero. ¿Algunas ideas? ExecutorService es =...
Estoy buscando una implementación ExecutorService que se pueda proporcionar con un tiempo de espera. Las tareas que se envían al ExecutorService se interrumpen si tardan más en ejecutarse que el tiempo de espera. Implementar tal bestia no es una tarea tan difícil, pero me pregunto si alguien...
A menudo encuentro que estos términos se utilizan en el contexto de la programación concurrente. ¿Son iguales o diferentes?
Estoy leyendo SIP-14 y el concepto de Futuretiene mucho sentido y es fácil de entender. Pero tengo dos preguntas sobre Promise: El SIP dice Depending on the implementation, it may be the case that p.future == p. ¿Cómo puede ser esto? ¿Son Futurey Promiseno dos tipos diferentes? ¿Cuándo...
a partir de Rails 4 , todo debería ejecutarse en un entorno de subprocesos de forma predeterminada. Lo que esto significa es que todo el código que escribimos Y TODAS las gemas que usamos deben serthreadsafe entonces, tengo algunas preguntas sobre esto: ¿Qué NO es seguro para subprocesos en...
¿Hay alguna ventaja de usar java.util.concurrent.CountdownLatch en vez de java.util.concurrent.Semaphore ? Por lo que puedo decir, los siguientes fragmentos son casi equivalentes: 1. Semáforo final Semaphore sem = new Semaphore(0); for (int i = 0; i < num_threads; ++ i) { Thread t =...
He estado observando la creciente visibilidad de los lenguajes de programación funcionales y las características durante un tiempo. Los miré y no vi el motivo de la apelación. Luego, recientemente asistí a la presentación "Basics of Erlang" de Kevin Smith en Codemash . Disfruté de la...
http://msdn.microsoft.com/en-us/library/system.threading.semaphoreslim.aspx Para crear un semáforo, necesito proporcionar un recuento inicial y un recuento máximo. MSDN indica que un recuento inicial es: El número inicial de solicitudes para el semáforo que se pueden otorgar al mismo...
En la programación de sockets, creas un socket de escucha y luego, para cada cliente que se conecta, obtienes un socket de flujo normal que puedes usar para manejar la solicitud del cliente. El sistema operativo gestiona la cola de conexiones entrantes detrás de escena. Dos procesos no se...
El javadoc para SimpleDateFormat indica que SimpleDateFormat no está sincronizado. "Los formatos de fecha no están sincronizados. Se recomienda crear instancias de formato independientes para cada subproceso. Si varios subprocesos acceden a un formato al mismo tiempo, debe sincronizarse...
Mientras investigaba el uso de Table Hints , me encontré con estas dos preguntas: ¿Qué sugerencias de bloqueo debo usar (T-SQL)? ¿Qué efecto tiene HOLDLOCK en UPDLOCK? Las respuestas a ambas preguntas dicen que cuando se usan (UPDLOCK, HOLDLOCK), otros procesos no podrán leer datos en esa...
¿Hay alguna explicación buena y breve de cómo funcionan los actores en comparación con los hilos? ¿No se puede ver un hilo como actor y enviar mensajes a otros hilos? Veo alguna diferencia, pero no me queda tan claro. ¿Puedo usar Actors en cualquier idioma usando hilos de manera diferente?...
Realmente me gustan estas herramientas cuando se trata del nivel de concurrencia que puede manejar. Erlang / OTP parece una solución mucho más estable, pero requiere mucho más aprendizaje y mucha inmersión en el paradigma del lenguaje funcional. Y parece que Erlang / OTP lo hace mucho mejor...
Cerrado . Esta pregunta debe estar más enfocada . Actualmente no acepta respuestas. ¿Quieres mejorar esta pregunta? Actualice la pregunta para que se centre en un solo problema editando esta publicación . Cerrado hace 5 años . Mejora esta pregunta...
En una versión anterior al lanzamiento de go 1.5 del sitio web Tour of Go , hay un fragmento de código que se ve así. package main import ( "fmt" "runtime" ) func say(s string) { for i := 0; i < 5; i++ { runtime.Gosched() fmt.Println(s) } } func main() { go say("world")...
Supongamos que tengo varios futuros y necesito esperar hasta que alguno de ellos falle o todos tengan éxito. Por ejemplo: Let hay 3 futuros: f1, f2, f3. Si f1tiene éxito y f2falla, no espero f3(y devuelvo la falla al cliente). Si f2falla mientras f1y f3siguen funcionando no los espero (y...
¿Es atómico acceder a un campo bool en C #? En particular, necesito poner un candado alrededor: class Foo { private bool _bar; //... in some function on any thread (or many threads) _bar = true; //... same for a read if (_bar) { ... } }
Acabo de ver esta estructura de datos en la API de Java 6 y tengo curiosidad acerca de cuándo sería un recurso útil. Estoy estudiando para el examen scjp y no lo veo cubierto en el libro de Kathy Sierra, aunque he visto preguntas de exámenes simulados que lo mencionan.
¿Estoy en lo cierto al pensar que este es el uso correcto de un diccionario concurrente? private ConcurrentDictionary<int,long> myDic = new ConcurrentDictionary<int,long>(); //Main thread at program startup for(int i = 0; i < 4; i++) { myDic.Add(i, 0); } //Seperate threads...
Tengo una clase que toma objetos de a BlockingQueuey los procesa llamando take()en un bucle continuo. En algún momento sé que no se agregarán más objetos a la cola. ¿Cómo interrumpo el take()método para que deje de bloquear? Aquí está la clase que procesa los objetos: public class MyObjHandler...