Mengapa `TCPListener` Go Tidak Menggunakan Saluran untuk Concurrency?

TCP Terima dan Model Concurrency Go

Soalan:

Mengapa TCPListener Go menggunakan menyekat kaedah Accept() dan bukannya sistem berasaskan saluran, seperti yang dijangkakan daripada penekanan Go pada concurrency?

Jawapan:

Model concurrency Go bergantung pada goroutines (benang ringan ) diuruskan oleh masa jalan Go. Walaupun Accept() mungkin kelihatan menyekat, ia akhirnya diuruskan oleh masa jalan Go, yang memilih goroutine untuk pelaksanaan. Ini membolehkan penggunaan sumber sistem yang cekap dan pelaksanaan operasi penyekatan yang mudah.

Pelaksanaan Saluran Tersuai:

Untuk mencapai sistem berasaskan saluran, anda boleh mencipta goroutine yang sentiasa menerima sambungan dan menolaknya ke saluran. Ini memberikan fleksibiliti untuk menggunakan select() dengan berbilang soket pelayan atau multipleks menunggu pada Accept() dengan saluran lain.

Pertimbangan Penutupan Saluran:

Perhatikan bahawa jika salah seorang penerima anda mengalami ralat, anda tidak boleh menutup saluran terima sahaja. Penerima lain akan panik apabila cuba menulis kepadanya.

Contoh:

<code class="go">newConns := make(chan net.Conn)

// For every listener, spawn a goroutine that accepts connections
for _, l := range listeners {
    go func(l net.Listener) {
        for {
            c, err := l.Accept()
            if err != nil {
                // Handle error
                newConns <- nil
                return
            }
            newConns <- c
        }
    }(l)
}

// Multiplex the channel with a timer
for {
    select {
    case c := <-newConns:
        // Handle new connection or nil (if an acceptor is down)
    case <-time.After(time.Minute):
        // Timeout branch
    }
}</code>

Atas ialah kandungan terperinci Mengapa `TCPListener` Go Tidak Menggunakan Saluran untuk Concurrency?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!