Senior
Taak: «Ping-pong met timeout» Schrijf een functie pingPong die: - Twee goroutines start: één genereert berichten "ping", de andere — "pong". - De goroutines moeten strikt om de beurt berichten uitwisselen via een gemeenschappelijk kanaal. - De uitwisseling duurt 3 seconden, waarna het programma moet afsluiten (gecontroleerde shutdown). - Gebruik een context voor annulering met timeout. - Geef elk bericht weer op het scherm samen met de tijd (in milliseconden vanaf de start). Voorbeeld van verwachte uitvoer: 0ms: ping
sobes.tech AI
Antwoord van AI
go package main
import ( "context" "fmt" "time" )
func pingPong() { ctx, cancel := context.WithTimeout(context.Background(), 3*time.Second) defer cancel()
ch := make(chan string)
start := time.Now()
// Функция для вывода с временем от старта
printMsg := func(msg string) {
elapsed := time.Since(start).Milliseconds()
fmt.Printf("%dms: %s\n", elapsed, msg)
}
// Горутина ping
go func() {
for {
select {
case <-ctx.Done():
return
case ch <- "ping":
}
}
}()
// Горутина pong
go func() {
for {
select {
case <-ctx.Done():
return
case msg := <-ch:
printMsg(msg)
if msg == "ping" {
ch <- "pong"
}
}
}
}()
// Главная горутина читает pong и выводит
for {
select {
case <-ctx.Done():
return
case msg := <-ch:
printMsg(msg)
}
}
}
func main() { pingPong() }
В этом решении две горутины обмениваются сообщениями через канал `ch`. Горутина `ping` отправляет "ping", горутина `pong` читает "ping", выводит и отправляет "pong" обратно. Главная горутина читает "pong" и выводит. Контекст с таймаутом 3 секунды обеспечивает graceful shutdown.