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...
¿Hay alguna forma de formatear un decimal de la siguiente manera? 100 -> "100" 100.1 -> "100.10" Si es un número redondo, omita la parte decimal. De lo contrario, formatee con dos lugares decimales.
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...
¿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...