Pergi - gelung berhenti selama-lamanya dengan konteks

Kandungan soalan

Saya mempunyai proses tak segerak yang sepatutnya kekal selama-lamanya, seperti ini:

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

func main() {
  go asyncforevertask()

  server.run(8080)
}

Saya mahu dapat menghentikan ini untuk gelung apabila permintaan tertentu sampai ke pelayan.

Saya tahu saya perlu menggunakan context.withcancel() tetapi saya tidak tahu cara mengintegrasikannya untuk berfungsi. Saya tahu sintaks berikut:

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

Tetapi asyncforevertask tidak dijalankan oleh isyarat dari mana-mana pihak lain, tetapi ia berjalan selama-lamanya. Saya seorang pemula dan sebarang bentuk bantuan amat dihargai.

Jawapan betul

Anda boleh menggunakan saluran untuk melakukan ini:

var stopasync = make(chan struct{})

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

Untuk membatalkan, tutup sahaja saluran. Anda perlu memastikan saluran ditutup sekali sahaja, jika tidak, anda akan panik.

Anda juga boleh melakukan ini melalui konteks:

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

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

atau:

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

Untuk berhenti, hubungi fungsi cancel yang dikembalikan:

...
cancel()

Jika anda juga perlu berhenti anytask, anda mesti sentiasa menyemak penutupan saluran atau penutupan konteks dan kembali daripada tugasan.

Atas ialah kandungan terperinci Pergi - gelung berhenti selama-lamanya dengan konteks. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!