Resultados de la búsqueda a petición "channel"
¿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 ...
El tiempo de espera de Golang no se ejecuta con canales
Estoy usando goroutines / canales. Aquí está mi código. ¿Por qué no se ejecuta el caso de tiempo de espera? func main() { c1 := make(chan int, 1) go func() { for { time.Sleep(1500 * time.Millisecond) c1 <- 10 } }() go func() { for { select { ...
Golang orden de salida del canal
func main() { messages := make(chan string) go func() { messages <- "hello" }() go func() { messages <- "ping" }() msg := <-messages msg2 := <-messages fmt.Println(msg) fmt.Println(msg2) El código anterior siempre imprime "ping" y luego "hola" en ...
go rutina para rango sobre canales
He estado trabajando en Golang durante mucho tiempo. Pero todavía estoy enfrentando este problema, aunque sé la solución a mi problema. Pero nunca descubrí por qué está sucediendo. Por ejemplo, si tengo una situación de canalización para ...
Pseudo canal Tcp
¿Qué es un canal pseudo-tcp y cómo se puede implementar?