Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
Estoy tratando de entender los contextos y canales en Go, pero estoy teniendo dificultades para comprender lo que está sucediendo. Aquí hay un código de ejemplo. package main import ( “context” “fmt” “log” “time” “golang.org/x/time/rate” ) func main() { msgs := make(chan string) ctx, cancel := context.WithTimeout(context.Background(), 1*time.Second) defer cancel() . . . Read more
Creo una ventana fltk con un botón. Cuando se hace clic en el botón, se genera un hilo con 10 iteraciones internas. Cada iteración envía un mensaje al canal. Con println!() todo funciona bien, pero si lo elimino, el canal comienza a omitir algunos mensajes. [dependencies] fltk = { version=”1.2.23″, . . . Read more
Me gustaría tener una función en Python que cree un par de canal de transmisión / recepción con el mismo o un mecanismo similar al de Rust: Estos canales tienen dos variantes: Un canal asincrónico con buffer infinito. La función [channel] devolverá una tupla (Sender, Receiver) en la que todos . . . Read more
Por favor, ¿hay alguna manera para que el remitente elimine los mensajes pendientes enviados a un canal mpsc (o crossbeam-channel o equivalente) que aún no han sido consumidos por el receptor? Algo similar a sender.deleteAllPending().
Necesito iterar sobre todos los valores que se encuentran actualmente almacenados en un receptor, y luego continuar con el resto del programa, que está implementado de esta manera: loop { match receiver.recv_timeout(std::time::Duration::from_nanos(0)) { Ok(value) => //hacer algo con el valor, _ => break } } Esto no parece ser la . . . Read more