¿Es posible comprobar si std::futureha finalizado o no? Por lo que puedo decir, la única forma de hacerlo sería llamar wait_forcon una duración cero y verificar si el estado es readyo no, pero ¿hay una mejor manera?
Tengo un solo archivo de texto grande en el que quiero procesar cada línea (hacer algunas operaciones) y almacenarlas en una base de datos. Dado que un solo programa simple está tardando demasiado, quiero que se realice a través de múltiples procesos o subprocesos. Cada hilo / proceso debe leer...
Tengo dos hilos, uno actualizando un int y otro leyéndolo. Este es un valor estadístico en el que el orden de las lecturas y escrituras es irrelevante. Mi pregunta es, ¿necesito sincronizar el acceso a este valor multibyte de todos modos? O, dicho de otra manera, puede que parte de la escritura...
Tengo un montón de propiedades en las que voy a usar bloqueos de lectura / escritura. Puedo implementarlos con una try finallyo una usingcláusula. En el try finallyI adquiriría el bloqueo antes del try, y lo liberaría en el finally. En la usingcláusula, crearía una clase que adquiere el bloqueo...
Tengo un método de extensión SafeInvoke Control similar al que Greg D analiza aquí (menos la verificación IsHandleCreated). Lo estoy llamando de la System.Windows.Forms.Formsiguiente manera: public void Show(string text) { label.SafeInvoke(()=>label.Text = text); this.Show();...
¿Cómo se implementa ThreadLocal? ¿Está implementado en Java (usando algún mapa concurrente de ThreadID al objeto), o usa algún gancho JVM para hacerlo de manera más eficiente?
Recientemente comencé a programar en WPF y me encontré con el siguiente problema. No entiendo cómo usar el Dispatcher.Invoke()método. Tengo experiencia en subprocesos y he creado algunos programas sencillos de Windows Forms en los que acabo de usar el Control.CheckForIllegalCrossThreadCalls =...
En ArrayBlockingQueue, todos los métodos que requieren el bloqueo lo copian en una finalvariable local antes de llamar lock(). public boolean offer(E e) { if (e == null) throw new NullPointerException(); final ReentrantLock lock = this.lock; lock.lock(); try { if (count == items.length)...
Utilizo visualVM para conectar una aplicación Java de múltiples subprocesos, el subproceso tiene 4 estados, es decir, en ejecución, en suspensión, en espera, en el Monitor. ¿Qué significa este estado de supervisión? ¿Cuál es la diferencia entre esperar y monitorizar?
Estoy ejecutando una aplicación C # y durante el tiempo de ejecución obtengo el siguiente error: El CLR no ha podido realizar la transición del contexto COM 0x20e480 al contexto COM 0x20e5f0 durante 60 segundos. Es muy probable que el hilo que posee el contexto / apartamento de destino esté...
Estoy haciendo un punto de referencia muy tonto en ReaderWriterLock con este código, donde la lectura ocurre 4 veces más a menudo que la escritura: class Program { static void Main() { ISynchro[] test = { new Locked(), new RWLocked() }; Stopwatch sw = new Stopwatch(); foreach ( var...
¿Qué tan grande es el grupo de subprocesos de Scala para futuros? Mi aplicación Scala genera muchos millones de future {}sy me pregunto si hay algo que pueda hacer para optimizarlos configurando un grupo de subprocesos. Gracias.
Tengo una tarea de apio intensiva en la CPU. Me gustaría usar toda la potencia de procesamiento (núcleos) en muchas instancias EC2 para hacer este trabajo más rápido (una tarea distribuida en paralelo de apio con multiprocesamiento, creo ) . Los términos, subprocesamiento , multiprocesamiento ,...
Encuentro que el modelo de eventos .NET es tal que a menudo generaré un evento en un hilo y lo escucharé en otro hilo. Me preguntaba cuál es la forma más limpia de organizar un evento desde un hilo de fondo en mi hilo de interfaz de usuario. Según las sugerencias de la comunidad, he usado...
cuál es la diferencia entre los siguientes ThreadPool.QueueUserWorkItem vs Task.Factory.StartNew Si el código anterior se llama 500 veces para alguna tarea de larga ejecución, ¿significa que se ocuparán todos los subprocesos del grupo de subprocesos? ¿O será TPL (segunda opción) lo...
¿Por qué la Threadclase se implementó como una clase regular y no como una clase abstracta con un run()método abstracto? ¿Posiblemente introducirá algún problema? ¿O tiene alguna utilidad en ser así? Además, Thread.start()se supone que el método es un método muy específico cuya funcionalidad...
Me he encontrado codificando este tipo de cosas varias veces. for (int i = 0; i < 10; i++) { if (Thing.WaitingFor()) { break; } Thread.Sleep(sleep_time); } if(!Thing.WaitingFor()) { throw new ItDidntHappenException(); } Parece un código incorrecto, ¿hay una mejor manera de hacer esto...
Tengo un EditText que toma un String del usuario y un searchButton. Cuando se hace clic en searchButton, buscará en el archivo XML y lo mostrará en ListView. Puedo tomar información del usuario, buscar en el archivo XML y mostrar el valor buscado por el usuario en ListView también. Lo que...
Tengo un hilo de trabajo que se encuentra en segundo plano, procesando mensajes. Algo como esto: class Worker extends Thread { public volatile Handler handler; // actually private, of course public void run() { Looper.prepare(); mHandler = new Handler() { // the Handler hooks up to the...
Escribí un simple programa multiproceso de la siguiente manera: static bool finished = false; int func() { size_t i = 0; while (!finished) ++i; return i; } int main() { auto result=std::async(std::launch::async, func); std::this_thread::sleep_for(std::chrono::seconds(1)); finished=true;...