DP
вопрос не ясен
Size: a a a
2020 February 26
АП
подольский написал бота?
К🇦
вопрос не ясен
var Wrk int = 20}
Ch := make(chan string, Wrkr)
for v := 0; v < 10; v++ {
Ch -> strconv.Itoa(v)
fmt.Println(" " + <-Ch)
АП
а это сообщение сработает?
вопрос не ясен
АП
Здравствуйте. У меня есть буферизованный канал, я пишу в него данные которые приходят из горутин которые запускаются в циклах порциями, и в последней порции может быть количество горутин меньше емкости канала. Чтение идет в цикле по емкости канала, соответственно идет ожидание появления записи в канале, как избежать этой блокировки?
если у тебя "воркеры" не успевают, все будут складироваться в канала пока есть место, потом будет блокировка
АП
вопрос как я понял - как избежать блокировку?
DP
var Wrk int = 20}
Ch := make(chan string, Wrkr)
for v := 0; v < 10; v++ {
Ch -> strconv.Itoa(v)
fmt.Println(" " + <-Ch)
так надо закрыть канал, когда в нем данные закончатся
К🇦
если у тебя "воркеры" не успевают, все будут складироваться в канала пока есть место, потом будет блокировка
нет, воркеры кончились, в канале нет записей и произходит блокировка при чтении
АП
а кто читает то?
К🇦
а кто читает то?
цикл
DP
еще можно читать в select с default
как только в канале не будет данных - сработает секция default
как только в канале не будет данных - сработает секция default
К🇦
еще можно читать в select с default
как только в канале не будет данных - сработает секция default
как только в канале не будет данных - сработает секция default
щас гуглану
К🇦
еще можно читать в select с default
как только в канале не будет данных - сработает секция default
как только в канале не будет данных - сработает секция default
Так?
for v := 0; v < Wrkr; v++ {
select {
case msg :=<-Ch:
fmt.Println(msg)
default:
fmt.Println("no message received")
return
}
}DP
ага
DP
то нет так
ВС
почти, тут идет два раза считывание из канала, надо в case первом писать вот так case v := <-Ch
DP
в этом цикле два чтения, результат первого теряется