Senior
Aufgabe: «Ping-Pong mit Timeout» Schreiben Sie eine Funktion pingPong, die: - Zwei Goroutines startet: eine generiert Nachrichten "ping", die andere — "pong". - Die Goroutines sollen Nachrichten strikt abwechselnd über einen gemeinsamen Kanal austauschen. - Der Austausch dauert 3 Sekunden, danach soll das Programm beendet werden (sauberes Herunterfahren). - Verwenden Sie einen Kontext zur Abbruchsteuerung mit Timeout. - Geben Sie jede Nachricht zusammen mit der Zeit (in Millisekunden seit Start) aus. Beispiel für die erwartete Ausgabe: 0ms: ping
sobes.tech KI
Antwort von 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.