Go – Schleife mit Kontext für immer stoppen

Frageninhalt

Ich habe einen asynchronen Prozess, der ewig dauern soll, so:

func asyncforevertask() {
  for {
    anytask()
  }
}

func main() {
  go asyncforevertask()

  server.run(8080)
}

Ich möchte diese for-Schleife stoppen können, wenn eine bestimmte Anfrage den Server erreicht.

Ich weiß, dass ich context.withcancel() verwenden muss, aber ich weiß nicht, wie ich es integrieren soll, damit es funktioniert. Ich kenne die folgende Syntax:

for {
  select {
  case <-ctx.Done:
    return
  case <-otherCh:
    // do smh.
  }
}

Aber asyncforevertask wird nicht durch ein Signal von irgendjemandem anderen gesteuert, sondern es läuft für immer. Ich bin ein Neuling und jede Art von Hilfe wird sehr geschätzt.

Richtige Antwort

Sie können dazu Kanäle verwenden:

var stopasync = make(chan struct{})

func asyncforevertask() {
  for {
    select {
      case <-stopasync:
         return
      default:
    }
    anytask()
  }
}

Um abzubrechen, schließen Sie einfach den Kanal. Sie müssen sicherstellen, dass der Kanal nur einmal geschlossen wird, sonst geraten Sie in Panik.

Sie können dies auch über den Kontext tun:

func main() {
   ctx,cancel:=context.withcancel(context.background())
   go asyncforevertask(ctx)
   ...
}

func asyncforevertask(ctx context.context) {
  for {
    select {
      case <-ctx.done():
         return
      default:
    }
    anytask()
  }
}

oder:

func asyncforevertask(ctx context.context) {
  for {
    if ctx.err()!=nil {
       return
    }
    anytask()
  }

Um anzuhalten, rufen Sie die zurückgegebene cancel-Funktion auf:

...
cancel()

Wenn Sie auch anhalten müssen anytask, müssen Sie immer prüfen, ob der Kanal oder der Kontext geschlossen ist, und von der Aufgabe zurückkehren.

Das obige ist der detaillierte Inhalt vonGo – Schleife mit Kontext für immer stoppen. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!