Resultados de la búsqueda a petición "future"
std :: función asíncrona que se ejecuta en serie
Cuando uso std :: async con launch :: async en un bucle for, mi código se ejecuta en serie en el mismo hilo, como si cada llamada asincrónica esperara a la anterior antes de iniciarse. En las notas para referencias std :: async (std :: async ...
¿Cuál es el mejor enfoque para encapsular el bloqueo de E / S en futuros rs?
yo leo eldocumentación de tokio [https://tokio.rs/docs/getting-started/tokio/]y me pregunto cuál es el mejor enfoque para encapsular costosas E / S sincrónicas en el futuro. Con el marco del reactor, obtenemos la ventaja de un modelo de ...
Llamar a una brillante devolución de llamada de JavaScript desde un futuro
En shiny, es posible llamar a las devoluciones de llamada del lado del cliente escritas en javascript desde la lógica del servidor. Decir enui.R tienes un JavaScript que incluye una función llamadasetText: tags$script(' ...
Excepción desconocida de std :: promise
¿Qué hay de malo con el siguiente código? Cuando se ejecuta, el programa aborta con una excepción desconocida #include <iostream> #include <future> int main() { auto promise = std::promise<int>{}; auto future_one = ...
¿Cómo pedirle a CompletableFuture que use hilos no daemon?
He escrito el siguiente código: System.out.println("Main thread:" + Thread.currentThread().getId()); CompletableFuture<Void> future = CompletableFuture.runAsync(() -> { try { System.out.println("Before sleep thread:" + ...
Secuenciando 'Future`s con tiempo de espera
Utilicé elTimeoutScheduler introducido enScala Futures: ¿tiempo de espera incorporado? [https://stackoverflow.com/questions/16304471/scala-futures-built-in-timeout]. Sin embargo, ahora mi programa no termina como antes ...
¿Por qué esto no está compilando? (RValue como argumentos CTOR de hilo)
Hola, aquí hay un código de prueba que escribí en MSVC12. ¿Alguien podría decirme por qué std :: move cuando paso parámetros al hilo no está convirtiendo las variables a referencias RValue? Y lo que debo hacer. ¡Gracias! ///some arbitrary long ...
capacidad de obtener el progreso en un objeto Future <T>
Con referencia al paquete java.util.concurrent y la interfaz Future, noto (a menos que me equivoque) que la capacidad de iniciar tareas largas y poder consultar sobre el progreso solo viene con la clase de implementación SwingWorker. Esto ...
Usando futuros en los actores de Akka
Estoy empezando a aprender Akka Actors en Scala. Tengo entendido que los mensajes recibidos por un actor se ponen en cola en el buzón de un actor y se procesan uno por uno. Al procesar los mensajes uno a la vez, se mitigan los problemas de ...
¿Es posible instalar una devolución de llamada después de que el procesamiento de la solicitud haya finalizado en Spray?
Estoy tratando de servir archivos temporales grandes de Spray. Necesito eliminar esos archivos una vez que se complete la solicitud HTTP. No pude encontrar una manera de hacer esto hasta ahora ... Estoy usando un código similar ...