unistack-org/micro-server-tcp
4
0
Fork 1
Code Issues Pull Requests Actions Packages Projects Releases 10 Wiki Activity

add waitGroups for waiting finish all connects #131

Merged
vtolstov merged 7 commits from devstigneev/micro-server-tcp:issue_130 into v3 2024-03-13 15:36:35 +03:00
Conversation 2 Commits 7 Files Changed 5 +1 -2
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit d7288c7130 - Show all commits

3
tcp.go
View File

@ -430,13 +430,12 @@ func (h *tcpServer) gracefulStop() {
done := make(chan struct{})
go func() {
h.opts.Wait.Wait()
vtolstov marked this conversation as resolved Outdated
vtolstov commented 2024-03-08 15:15:46 +03:00
Outdated
Review
Copy Link

смотри, лучше сделать канал и если вейтгруппа кончилась- прямо там закрывать канал, тогда в селекте мы сразу попадем на нужный кейс

смотри, лучше сделать канал и если вейтгруппа кончилась- прямо там закрывать канал, тогда в селекте мы сразу попадем на нужный кейс
devstigneev commented 2024-03-08 15:36:45 +03:00
Outdated
Review
Copy Link

да, я прикинул потом, что закрытие нужно сместить

да, я прикинул потом, что закрытие нужно сместить
done <- struct{}{}
close(done)
}()
select {
case <-tm.C:
case <-done:
devstigneev commented 2024-03-06 13:02:16 +03:00
Outdated
Review
Copy Link

Тут мы ждем либо у нас концертны все закрылись и вызвался cancel()
либо ctx.Done выполнился по GracefulTimeout

Тут мы ждем либо у нас концертны все закрылись и вызвался cancel() либо ctx.Done выполнился по GracefulTimeout
devstigneev commented 2024-03-06 13:04:05 +03:00
Outdated
Review
Copy Link

если я использую time.Timer, не совсем смог прийти к решению, что я его в ручную остановил и мог без препятствий завершить метод

если я использую time.Timer, не совсем смог прийти к решению, что я его в ручную остановил и мог без препятствий завершить метод
devstigneev commented 2024-03-06 13:05:05 +03:00
Outdated
Review
Copy Link

но возникает другая проблема, если Wait - залочился, то горутина с ней утекла

но возникает другая проблема, если Wait - залочился, то горутина с ней утекла
close(done)
}
}