Golang menyalin semua nilai konteks

Kandungan soalan

Saya mempunyai aplikasi pelayan HTTP yang menyediakan kerja tak segerak.

-> Request
   --> Do async job with goroutine
<- Response
    -------start goroutine------
       -> Job1
          -> Job1A
          -> Job1B
       -> Job2
       -> Job3

Pengguna boleh meminta kerja tak segerak yang berjalan lama dan aplikasi bertindak balas kepada permintaan itu serta-merta selepas membuat goroutine.

Saya meletakkan ID permintaan, token yang disahkan dan maklumat pengguna ke dalam permintaan context.Context 中。而且，我想把它放在 goroutine 下。但是，对请求 context 使用相同的 context yang menyebabkan pembatalan yang tidak dijangka selepas respons, yang bukan tingkah laku yang saya maksudkan.

Bagaimana untuk menjana context，独立于父请求 context？或者，还有其他方法可以保证 context baharu dengan semua nilai tanpa mati selepas membawa masuk tindak balas goroutine?

Dan soalan bonus:

Pembatalan

Job1 ~ Job3 应该被序列化，即 Job2 应该等待 Job1 和 Job3 等待 Job2。并且，Job1A 和 Job1B 可以同时运行。如果我想传播给定 context, bagaimana saya boleh membatalkan laluan mereka(?)? Perlukah saya menyemak penyata pilih untuk semua fungsi?

Saya faham context Sebarkan konsep pembatalan dan keluar awal tanpa melakukan tugas sia-sia. Walau bagaimanapun, saya tidak tahu bagaimana untuk mengendalikan ini dalam kod. Saya akan gembira jika seseorang boleh membantu memahami.

Jawapan Betul

Nilai dalam konteks tidak dapat ditemui. Ia tidak disimpan sebagai peta, tetapi sebagai lapisan konteks, setiap peringkat berpotensi menyediakan pelaksanaan yang berbeza tentang cara nilai disimpan.

Walau bagaimanapun, jika anda tahu nilai mana yang perlu disebarkan, anda boleh menanyakannya dan mencipta konteks baharu dengan nilai tersebut.

Iaitu, anda boleh melaksanakan jenis konteks baharu yang menggunakan nilai daripada konteks lain:

type newContext struct {
  context.Context
  values context.Context
}

func (c newContext) Value(key any) any {
  return c.values.Value(key)
}

...
newCtx:=newContext{
  Context: context.Background(),
  values: ctx,
}

Ini menggunakan konteks nilai sedia ada dan konteks baharu untuk semua perkara lain.

Kemudian, mulakan goroutine baharu untuk meneruskan memproses permintaan menggunakan konteks baharu.

Jika anda ingin mencipta beberapa pekerjaan serentak, anda boleh melakukan ini dalam goroutine ini:

go func(ctx context.Context) {
   withCancel, cancel:=context.WithCancel(ctx)
   defer cancel()

   wg:=sync.WaitGroup{}
   wg.Add(2)
   go job1(withCancel,&wg)
   go job2(withCancel,&wg)
   wg.Wait()
}(newCtx)

Dengan cara ini, apabila konteks dibatalkan, kedua-dua kerja akan menerima pemberitahuan pembatalan. Jika anda ingin mengawal pembatalan job1 dan job2 secara berasingan:

go func(ctx context.Context) {
   withCancel1, cancel1:=context.WithCancel(ctx)
   defer cancel1()
   withCancel2, cancel2:=context.WithCancel(ctx)
   defer cancel2()

   wg:=sync.WaitGroup{}
   wg.Add(2)
   go job1(withCancel1,&wg)
   go job2(withCancel2,&wg)
   wg.Wait()
}(newCtx)

Untuk kerja berturut-turut (iaitu job3 selesai selepas kerja1), cuma gabungkan mereka supaya kelihatan seperti satu kerja.

Untuk menyemak sama ada konteks telah dibatalkan, anda boleh melakukan ini dalam konteks Done 通道上执行 select , atau semak sahaja:

if ctx.Err()!=nil {
   // Context canceled
}

Atas ialah kandungan terperinci Golang menyalin semua nilai konteks. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!