Resultados da pesquisa a pedido "channel"
Impedir que o canal do arquivo seja fechado após a leitura do arquivo xml
Para obter informações mais detalhadas sobre a motivação por trás desse objetivo (e meus esforços para resolvê-lo), veja meupergunta anterior [https://stackoverflow.com/questions/26587631/concurrently-write-to-xml-file]. Decidi fazer isso como ...
A Goroutine não é executada se houver tempo.
O código a seguir funciona perfeitamente: 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] No entanto, se eu ...
Como uso vidas estáticas com threads?
Atualmente, estou lutando com as vidas em Rust (1.0), especialmente quando se trata de passar estruturas por canais. Como eu obteria este exemplo simples para compilar: use std::sync::mpsc::{Receiver, Sender}; use std::sync::mpsc; ...
O "trabalhador" de desligamento passa a rotina após o buffer estar vazio
Quero meu trabalhador de rotina (ProcessToDo() no código abaixo) para aguardar até que todo o trabalho "em fila" seja processado antes de desligar. A rotina de trabalho possui um canal "pendente" (em buffer), através do qual o trabalho é enviado ...
Canais de mensagem um ou muitos?
Preciso lidar com e-mails de cerca de 30 endereços. Eu implico isso de uma maneira em que todos os emails que vão para umDirectChannel e depois deReceiver. NoReceiver Eu posso entender de que endereço vem a mensagem, para isso ...
Não é possível sair da variável externa capturada em um fechamento `Fn`
Estou tentando descobrir como enviar uma função através de um canal e como evitar a clonagem extra para executar a função no outro extremo. Se eu remover a operação de clonagem extra dentro do fechamento, recebo o seguinte erro: error: cannot ...
Como transmitir uma mensagem de um Phoenix Controller para um canal?
Existe uma maneira de transmitir uma mensagem para um canal de fora desse canal? Talvez algo comoChannel.broadcast topic, event, data? Eu vi algo assimaqui [https://github.com/phoenixframework/phoenix/issues/70]mas a versão final ...
Canal de fechamento de comprimento desconhecido
Não consigo fechar o canal quando não há conhecimento sobre sua comprimento 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 ...
O tempo limite de Golang não é executado com canais
Estou usando goroutines / canais. Aqui está o meu código. Por que o caso de tempo limite não está sendo executado? func main() { c1 := make(chan int, 1) go func() { for { time.Sleep(1500 * time.Millisecond) c1 <- 10 } }() go func() { for { ...
go rotina para o alcance sobre canais
Estive trabalhando em Golang há muito tempo. Mas ainda estou enfrentando esse problema, embora conheça a solução para o meu problema. Mas nunca descobri por que isso está acontecend Por exemplo, se eu tiver uma situação de pipeline para canais ...