Resultados de la búsqueda a petición "channel"
Llamadas concurrentes de WCF por canal compartido
Tengo un nivel web que reenvía las llamadas a un nivel de aplicación. El nivel web utiliza un canal compartido en caché para hacerlo. Los servicios de nivel de aplicación en cuestión no tienen estado y tienen concurrencia habilitada. Pero no se ...
forma correcta de esperar a que termine una rutina
Deseo saber cuál es la forma correcta de esperar a que termine una rutina antes de salir del programa. Al leer algunas otras respuestas, parece que un bool chan hará el truco, como enEnlace de juegos [http://play.golang.org/p/ZFnygUtdSY] func ...
Evite que el canal del archivo se cierre después de leer el archivo xml
Para obtener información más detallada sobre la motivación detrás de este objetivo (y mis esfuerzos para resolverlo) vea miPregunta anterior [https://stackoverflow.com/questions/26587631/concurrently-write-to-xml-file]. Decidí hacer esto como una ...
Goroutine no se ejecuta si se incluye el tiempo.
El siguiente código funciona perfectamente bien: package main import ( "fmt" ) func my_func(c chan int){ fmt.Println(<-c) } func main(){ c := make(chan int) go my_func(c) c<-3 }playgound_1 [https://play.golang.org/p/A1iylDEsv1] Sin embargo si ...
¿Cómo uso vidas estáticas con hilos?
Actualmente estoy luchando con vidas en Rust (1.0), especialmente cuando se trata de pasar estructuras a través de canales. ¿Cómo obtendría este sencillo ejemplo para compilar? use std::sync::mpsc::{Receiver, Sender}; use std::sync::mpsc; ...
Apague la rutina de "trabajador" después de que el búfer esté vacío
Quiero que mi trabajador de rutina vayaProcessToDo() en el código a continuación) para esperar hasta que se procese todo el trabajo "en cola" antes de cerrar. La rutina de trabajo tiene un canal "para hacer" (almacenado), a través del cual se le ...
¿Canales de mensajes uno o muchos?
Necesito manejar correos electrónicos de aproximadamente 30 direcciones. Implemento esto de una manera donde todos los correos electrónicos van a unoDirectChannel y después deReceiver. EnReceiver Puedo entender de qué dirección viene el mensaje, ...
No se puede mover fuera de la variable externa capturada en un cierre `Fn`
Estoy tratando de descubrir cómo enviar una función a través de un canal y cómo evitar la clonación adicional para ejecutar la función en el otro extremo. Si elimino la operación de clonación adicional dentro del cierre, aparece el siguiente ...
¿Cómo transmitir un mensaje de un controlador Phoenix a un canal?
¿Hay alguna manera de transmitir un mensaje a un canal desde fuera de ese canal? Tal vez algo comoChannel.broadcast topic, event, data? Vi algo como estoaquí [https://github.com/phoenixframework/phoenix/issues/70] pero la versión final ...
Canal de cierre de longitud desconocida
No puedo cerrar el canal cuando no tengo conocimiento sobre su longitud package main import ( "fmt" "time" ) func gen(ch chan int) { var i int for { time.Sleep(time.Millisecond * 10) ch <- i i++ // when no more data (e.g. from db, or event ...