Preguntas etiquetadas con multithreading

157
Implementar C # Generic Timeout

Estoy buscando buenas ideas para implementar una forma genérica de ejecutar una sola línea (o delegado anónimo) de código con un tiempo de espera. TemperamentalClass tc = new TemperamentalClass(); tc.DoSomething(); // normally runs in 30 sec. Want to error at 1 min Estoy buscando una solución que...

156
Python Threading String Arguments

Tengo un problema con el subproceso de Python y el envío de una cadena en los argumentos. def processLine(line) : print "hello"; return; . dRecieved = connFile.readline(); processThread = threading.Thread(target=processLine, args=(dRecieved)); processThread.start(); Donde dRecieved es la...

156
¿Qué significa este código de unión de hilo?

En este código, ¿qué significan las dos uniones y la ruptura? t1.join()hace t2que pare hasta que t1termina? Thread t1 = new Thread(new EventThread("e1")); t1.start(); Thread t2 = new Thread(new EventThread("e2")); t2.start(); while (true) { try { t1.join(); t2.join(); break; } catch...

153
¿Puede num ++ ser atómico para 'int num'?

En general, for int num, num++(or ++num), como una operación de lectura-modificación-escritura, no es atómica . Pero a menudo veo que los compiladores, por ejemplo GCC , generan el siguiente código ( intente aquí ): Dado que la línea 5, que corresponde a num++una instrucción, ¿podemos concluir que...

145
Esperando en una lista de Futuro

Tengo un método que devuelve un Listfuturo List<Future<O>> futures = getFutures(); Ahora quiero esperar hasta que todos los futuros se terminen de procesar con éxito o cualquiera de las tareas cuyo resultado sea devuelto por un futuro arroje una excepción. Incluso si una tarea arroja...