Penjadwal GO: Sekarang Bukan Koperasi?

Persyaratan sistem

• memahami prinsip-prinsip penjadwal (walaupun saya akan mencoba menjelaskan di bawah ini, "dengan jari")
• memahami cara kerja pengumpul sampah
• memahami apa itu GO assembler

Secara singkat tentang perencana

• Prosesor P - logis (kita dapat mengubah angka mereka dengan fungsi runtime.GOMAXPROCS), pada setiap prosesor logis satu goroutine dapat dieksekusi secara mandiri pada satu waktu.
• Utas M - OS. Setiap P berjalan pada utas dari M. Perhatikan bahwa P tidak selalu sama dengan M, misalnya, utas dapat diblokir oleh syscall dan kemudian utas lainnya akan dialokasikan untuk P. Dan ada CGO dan nuansa lainnya dan lainnya.
• G - gorutins. Nah di sini jelas, G harus dijalankan pada setiap P dan scheduler memonitor ini.

Dan apa masalahnya sebenarnya?

func main() {
	runtime.GOMAXPROCS(1)
	go func() {
		var u int
		for {
			u -= 2
			if u == 1 {
				break
			}
		}
	}()
	<-time.After(time.Millisecond * 5) //    main   ,         

	fmt.Println("go 1.13 has never been here")
}

Usulkan proposal

Apakah Anda pergi ke sana, GC?

j := &someStruct{}
p := unsafe.Pointer(j)
// unsafe-point start
u := uintptr(p)
//do some stuff here
p = unsafe.Pointer(u)
// unsafe-point end

Mari kita lanjutkan berlatih

15.652 ( 0.003 ms): main/29614 tgkill(tgid: 29613 (main), pid: 29613 (main), sig: URG                ) = 0

func signalM(mp *m, sig int) {
	tgkill(getpid(), int(mp.procid), sig)
}

1. saat goroutine ditangguhkan, jika sedang dalam kondisi berjalan. Permintaan penangguhan berasal dari pengumpul sampah. Di sini, mungkin, saya tidak akan menambahkan kode, tetapi dapat ditemukan di file runtime / preempt.go (suspendG)
2. jika penjadwal memutuskan bahwa goroutine bekerja terlalu lama, runtime / proc.go (retake)
   

   
   if pd.schedwhen+forcePreemptNS <= now {
   	signalM(_p_)
   }
   

   
   forcePreemptNS - konstan sama dengan 10ms, pd.schedwhen - waktu ketika scheduler untuk aliran pd disebut terakhir kali
   
3. serta semua aliran sinyal ini dikirim selama kepanikan, StopTheWorld (GC) dan beberapa kasus lainnya (yang harus saya bypass, karena ukuran artikel sudah akan melampaui batas)

func doSigPreempt(gp *g, ctxt *sigctxt) {
	if wantAsyncPreempt(gp) && isAsyncSafePoint(gp, ctxt.sigpc(), ctxt.sigsp(), ctxt.siglr()) {
		// Inject a call to asyncPreempt.
		ctxt.pushCall(funcPC(asyncPreempt))
	}
}

1. wantAsyncPreempt - kami memeriksa apakah G ingin dipaksa keluar, di sini, misalnya, validitas status goroutine saat ini akan diperiksa.
2. isAsyncSafePoint - periksa apakah itu bisa ramai sekarang. Yang paling menarik dari cek di sini adalah apakah G berada di titik aman atau tidak aman. Selain itu, kita harus yakin bahwa utas yang menjalankan G juga siap untuk mendahului G.

Dan lebih lanjut tentang tidak aman

//go:nosplit
func infiniteLoop() {
	var u int
	for {
		u -= 2
		if u == 1 {
			break
		}
	}
}

func main() {
	runtime.GOMAXPROCS(1)
	go infiniteLoop()
	<-time.After(time.Millisecond * 5)

	fmt.Println("go 1.13 and 1.14 has never been here")
}

        0x0000 00000 (main.go:10)   TEXT    "".infiniteLoop(SB), NOSPLIT|ABIInternal, $0-0
        0x0000 00000 (main.go:10)   PCDATA  $0, $-2
        0x0000 00000 (main.go:10)   PCDATA  $1, $-2
        0x0000 00000 (main.go:10)   FUNCDATA        $0, gclocals·33cdeccccebe80329f1fdbee7f5874cb(SB)
        0x0000 00000 (main.go:10)   FUNCDATA        $1, gclocals·33cdeccccebe80329f1fdbee7f5874cb(SB)
        0x0000 00000 (main.go:10)   FUNCDATA        $2, gclocals·33cdeccccebe80329f1fdbee7f5874cb(SB)
        0x0000 00000 (main.go:10)   XORL    AX, AX
        0x0002 00002 (main.go:12)   JMP     8
        0x0004 00004 (main.go:13)   ADDQ    $-2, AX
        0x0008 00008 (main.go:14)   CMPQ    AX, $3
        0x000c 00012 (main.go:14)   JNE     4
        0x000e 00014 (main.go:15)   PCDATA  $0, $-1
        0x000e 00014 (main.go:15)   PCDATA  $1, $-1
        0x000e 00014 (main.go:15)   RET

	smi := pcdatavalue(f, _PCDATA_RegMapIndex, pc, nil)
	if smi == -2 {
		return false
	}

Kesimpulan