Rumah pembangunan bahagian belakang Golang Goroutine dan Saluran: Corak Konkurensi dalam Go

Goroutine dan Saluran: Corak Konkurensi dalam Go

Dec 13, 2024 am 05:55 AM

Concurrency membolehkan kami mengendalikan berbilang tugasan secara bebas antara satu sama lain. Goroutine ialah cara mudah untuk memproses berbilang tugas secara bebas. Dalam siaran ini, kami secara beransur-ansur meningkatkan pengendali http yang menerima fail dan meneroka pelbagai corak konkurensi dalam Go menggunakan saluran dan pakej penyegerakan.

Persediaan

Sebelum memasuki corak konkurensi, mari kita sediakan peringkat. Bayangkan kami mempunyai pengendali HTTP yang menerima berbilang fail melalui borang dan memproses fail dalam beberapa cara.

func processFile(file multipart.File) {
   // do something with the file
   fmt.Println("Processing file...")
   time.Sleep(100 * time.Millisecond) // Simulating file processing time
}
func UploadHandler(w http.ResponseWriter, r *http.Request) {
   // limit to 10mb 
   if err := r.ParseMultipartForm(10 << 20); err != nil {
       http.Error(w, "Unable to parse form", http.StatusBadRequest)
       return 
   }
   // iterate through all files and process them sequentially 
   for _, file := range r.MultipartForm.File["files"] {
       f, err := file.Open()
       if err != nil {
          http.Error(w, "Unable to read file", http.StatusInternalServerError)
          return
       }
       processFile(f)
       f.Close()
   }
}
Salin selepas log masuk
Salin selepas log masuk

Dalam contoh di atas, kami menerima fail daripada borang dan memprosesnya secara berurutan. Jika 10 fail dimuat naik, ia akan mengambil masa 1 saat untuk menyelesaikan proses dan menghantar respons kepada pelanggan.
Apabila mengendalikan banyak fail ini boleh menjadi halangan, namun dengan sokongan serentak Go kami boleh menyelesaikan isu ini dengan mudah.

Kumpulan Tunggu

Untuk menyelesaikannya, kami boleh memproses fail secara serentak. Untuk menghasilkan goroutine baharu kita boleh awalan panggilan fungsi dengan kata kunci go cth. pergi processFile(f). Walau bagaimanapun, kerana goroutine tidak menyekat pengendali mungkin kembali sebelum proses selesai, meninggalkan fail mungkin tidak diproses atau mengembalikan keadaan yang tidak betul. Untuk menunggu pemprosesan semua fail, kami boleh menggunakan penyegerakan.WaitGroup.
WaitGroup menunggu beberapa goroutine selesai, untuk setiap goroutine yang kami hasilkan, kami juga harus meningkatkan pembilang dalam WaitGroup ini boleh dilakukan dengan fungsi Tambah. Apabila goroutine selesai Selesai perlu dipanggil supaya kaunter berkurangan satu. Sebelum kembali dari fungsi Wait perlu dipanggil yang menyekat sehingga kaunter WaitGroup ialah 0.

func UploadHandler(w http.ResponseWriter, r *http.Request) {
   if err := r.ParseMultipartForm(10 << 20); err != nil {
       http.Error(w, "Unable to parse form", http.StatusBadRequest)
       return
   }

   // create WaitGroup 
   var wg sync.WaitGroup 
   for _, file := range r.MultipartForm.File["files"] {
       f, err := file.Open()
       if err != nil {
          http.Error(w, "Unable to read file", http.StatusInternalServerError)
          return
       }

       wg.Add(1) // Add goroutine to the WaitGroup by incrementing the WaitGroup counter, this should be called before starting a goroutine
       // Process file concurrently
       go func(file multipart.File) {
           defer wg.Done() // decrement the counter by calling Done, utilize defer to guarantee that Done is called. 
           defer file.Close()
           processFile(f)
       }(f)
   }

   // Wait for all goroutines to complete
   wg.Wait()
   fmt.Fprintln(w, "All files processed successfully!")
}
Salin selepas log masuk
Salin selepas log masuk

Sekarang untuk setiap fail yang dimuat naik, goroutine baharu dihasilkan ini boleh membebankan sistem. Satu penyelesaian adalah dengan mengehadkan bilangan goroutin yang bertelur.

Mengehadkan Keselarasan Dengan Semaphore

Semaphore hanyalah pembolehubah yang boleh kita gunakan untuk mengawal akses kepada sumber biasa melalui berbilang urutan atau dalam kes ini goroutine.

Dalam Go kita boleh menggunakan saluran penimbal untuk melaksanakan semaphore.

Saluran

Sebelum masuk ke dalam pelaksanaan, mari kita lihat apakah saluran dan perbezaan antara saluran penimbal dan tidak penimbal.

Saluran ialah saluran yang melaluinya kami boleh menghantar dan menerima data untuk berkomunikasi dengan selamat antara rutin pergi.
Saluran mesti dibuat dengan fungsi make.

func processFile(file multipart.File) {
   // do something with the file
   fmt.Println("Processing file...")
   time.Sleep(100 * time.Millisecond) // Simulating file processing time
}
func UploadHandler(w http.ResponseWriter, r *http.Request) {
   // limit to 10mb 
   if err := r.ParseMultipartForm(10 << 20); err != nil {
       http.Error(w, "Unable to parse form", http.StatusBadRequest)
       return 
   }
   // iterate through all files and process them sequentially 
   for _, file := range r.MultipartForm.File["files"] {
       f, err := file.Open()
       if err != nil {
          http.Error(w, "Unable to read file", http.StatusInternalServerError)
          return
       }
       processFile(f)
       f.Close()
   }
}
Salin selepas log masuk
Salin selepas log masuk

Saluran mempunyai operator khas <- yang digunakan untuk menghantar atau membaca daripada saluran.
Mempunyai titik operator pada saluran ch <- 1 menghantar data ke saluran, jika anak panah menghala jauh dari saluran <-ch nilai akan diterima. Operasi hantar dan terima disekat secara lalai ini bermakna setiap operasi akan menunggu sehingga pihak lain bersedia.

Goroutines and Channels: Concurrency Patterns in Go
Animasi menggambarkan pengeluar menghantar nilai 1 melalui saluran yang tidak ditimbal dan pengguna membaca dari saluran tersebut.

Jika pengeluar boleh menghantar acara lebih cepat daripada yang boleh dikendalikan oleh pengguna, maka kami mempunyai pilihan untuk menggunakan saluran penimbal untuk mengatur baris berbilang mesej tanpa menyekat pengeluar sehingga penimbal penuh. Pada masa yang sama pengguna boleh mengendalikan mesej mengikut kadarnya sendiri.

func UploadHandler(w http.ResponseWriter, r *http.Request) {
   if err := r.ParseMultipartForm(10 << 20); err != nil {
       http.Error(w, "Unable to parse form", http.StatusBadRequest)
       return
   }

   // create WaitGroup 
   var wg sync.WaitGroup 
   for _, file := range r.MultipartForm.File["files"] {
       f, err := file.Open()
       if err != nil {
          http.Error(w, "Unable to read file", http.StatusInternalServerError)
          return
       }

       wg.Add(1) // Add goroutine to the WaitGroup by incrementing the WaitGroup counter, this should be called before starting a goroutine
       // Process file concurrently
       go func(file multipart.File) {
           defer wg.Done() // decrement the counter by calling Done, utilize defer to guarantee that Done is called. 
           defer file.Close()
           processFile(f)
       }(f)
   }

   // Wait for all goroutines to complete
   wg.Wait()
   fmt.Fprintln(w, "All files processed successfully!")
}
Salin selepas log masuk
Salin selepas log masuk

Dalam contoh ini pengeluar boleh menghantar sehingga dua item tanpa menyekat. Apabila kapasiti penimbal dicapai pengeluar akan menyekat sehingga pengguna mengendalikan sekurang-kurangnya satu mesej.

Goroutines and Channels: Concurrency Patterns in Go

Berbalik kepada masalah awal kami ingin mengehadkan jumlah fail pemprosesan goroutine secara serentak. Untuk melakukan ini, kami boleh menggunakan saluran penimbal.

ch := make(chan int)
Salin selepas log masuk

Dalam contoh ini kami menambah saluran penimbal dengan kapasiti 5, ini membolehkan kami memproses 5 fail serentak dan mengehadkan ketegangan pada sistem.

Tetapi bagaimana jika tidak semua fail adalah sama? Kami mungkin boleh meramalkan dengan pasti bahawa jenis fail atau saiz fail yang berbeza memerlukan lebih banyak sumber untuk diproses. Dalam kes ini kita boleh menggunakan semaphore berwajaran.

Semaphore berwajaran

Ringkasnya dengan semafor berwajaran kita boleh memperuntukkan lebih banyak sumber untuk satu tugasan. Go sudah menyediakan pelaksanaan untuk semaphore berwajaran dalam pakej penyegerakan lanjutan.

ch := make(chan int, 2)
Salin selepas log masuk

Dalam versi ini kami mencipta semaphore berwajaran dengan 5 slot, jika hanya imej yang dimuat naik contohnya proses mengendalikan 5 imej secara serentak, namun jika PDF dimuat naik 2 slot diperoleh, yang akan mengurangkan jumlah fail yang boleh dikendalikan serentak.

Kesimpulan

Kami meneroka beberapa corak konkurensi dalam Go, menggunakan penyegerakan.WaitGroup dan semaphore untuk mengawal bilangan tugasan serentak. Walau bagaimanapun terdapat lebih banyak alat yang tersedia, kami boleh menggunakan saluran untuk mencipta kumpulan pekerja, menambah tamat masa atau menggunakan corak kipas masuk/keluar.
Selain itu, pengendalian ralat adalah aspek penting yang kebanyakannya ditinggalkan untuk kesederhanaan.
Satu cara untuk mengendalikan ralat akan digunakan saluran untuk mengagregat ralat dan mengendalikannya selepas semua goroutine selesai.

Go juga menyediakan errgroup.Group yang berkaitan dengan sync.WaitGroups tetapi menambah pengendalian tugas yang mengembalikan ralat.
Pakej boleh didapati dalam pakej penyegerakan lanjutan.

Atas ialah kandungan terperinci Goroutine dan Saluran: Corak Konkurensi dalam Go. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!

Kenyataan Laman Web ini
Kandungan artikel ini disumbangkan secara sukarela oleh netizen, dan hak cipta adalah milik pengarang asal. Laman web ini tidak memikul tanggungjawab undang-undang yang sepadan. Jika anda menemui sebarang kandungan yang disyaki plagiarisme atau pelanggaran, sila hubungi admin@php.cn

Alat AI Hot

Undresser.AI Undress

Undresser.AI Undress

Apl berkuasa AI untuk mencipta foto bogel yang realistik

AI Clothes Remover

AI Clothes Remover

Alat AI dalam talian untuk mengeluarkan pakaian daripada foto.

Undress AI Tool

Undress AI Tool

Gambar buka pakaian secara percuma

Clothoff.io

Clothoff.io

Penyingkiran pakaian AI

Video Face Swap

Video Face Swap

Tukar muka dalam mana-mana video dengan mudah menggunakan alat tukar muka AI percuma kami!

Artikel Panas

<🎜>: Bubble Gum Simulator Infinity - Cara Mendapatkan dan Menggunakan Kekunci Diraja
4 minggu yang lalu By 尊渡假赌尊渡假赌尊渡假赌
Nordhold: Sistem Fusion, dijelaskan
4 minggu yang lalu By 尊渡假赌尊渡假赌尊渡假赌
Mandragora: Whispers of the Witch Tree - Cara Membuka Kunci Cangkuk Bergelut
3 minggu yang lalu By 尊渡假赌尊渡假赌尊渡假赌

Alat panas

Notepad++7.3.1

Notepad++7.3.1

Editor kod yang mudah digunakan dan percuma

SublimeText3 versi Cina

SublimeText3 versi Cina

Versi Cina, sangat mudah digunakan

Hantar Studio 13.0.1

Hantar Studio 13.0.1

Persekitaran pembangunan bersepadu PHP yang berkuasa

Dreamweaver CS6

Dreamweaver CS6

Alat pembangunan web visual

SublimeText3 versi Mac

SublimeText3 versi Mac

Perisian penyuntingan kod peringkat Tuhan (SublimeText3)

Topik panas

Tutorial Java
1672
14
Tutorial PHP
1276
29
Tutorial C#
1256
24
Golang vs Python: Prestasi dan Skala Golang vs Python: Prestasi dan Skala Apr 19, 2025 am 12:18 AM

Golang lebih baik daripada Python dari segi prestasi dan skalabiliti. 1) Ciri-ciri jenis kompilasi Golang dan model konkurensi yang cekap menjadikannya berfungsi dengan baik dalam senario konvensional yang tinggi. 2) Python, sebagai bahasa yang ditafsirkan, melaksanakan perlahan -lahan, tetapi dapat mengoptimumkan prestasi melalui alat seperti Cython.

Golang dan C: Konvensyen vs kelajuan mentah Golang dan C: Konvensyen vs kelajuan mentah Apr 21, 2025 am 12:16 AM

Golang lebih baik daripada C dalam kesesuaian, manakala C lebih baik daripada Golang dalam kelajuan mentah. 1) Golang mencapai kesesuaian yang cekap melalui goroutine dan saluran, yang sesuai untuk mengendalikan sejumlah besar tugas serentak. 2) C Melalui pengoptimuman pengkompil dan perpustakaan standard, ia menyediakan prestasi tinggi yang dekat dengan perkakasan, sesuai untuk aplikasi yang memerlukan pengoptimuman yang melampau.

Bermula dengan Go: Panduan Pemula Bermula dengan Go: Panduan Pemula Apr 26, 2025 am 12:21 AM

GoisidealforbeginnersandSuekableforcloudandnetworkservicesduetoitssimplicity, kecekapan, danconcurrencyfeatures.1) installgofromtheofficialwebsiteandverifywith'goversion'.2)

Golang vs C: Perbandingan Prestasi dan Kelajuan Golang vs C: Perbandingan Prestasi dan Kelajuan Apr 21, 2025 am 12:13 AM

Golang sesuai untuk pembangunan pesat dan senario serentak, dan C sesuai untuk senario di mana prestasi ekstrem dan kawalan peringkat rendah diperlukan. 1) Golang meningkatkan prestasi melalui pengumpulan sampah dan mekanisme konvensional, dan sesuai untuk pembangunan perkhidmatan web yang tinggi. 2) C mencapai prestasi muktamad melalui pengurusan memori manual dan pengoptimuman pengkompil, dan sesuai untuk pembangunan sistem tertanam.

Impak Golang: Kelajuan, Kecekapan, dan Kesederhanaan Impak Golang: Kelajuan, Kecekapan, dan Kesederhanaan Apr 14, 2025 am 12:11 AM

Goimpactsdevelopmentpositivielythroughspeed, efficiency, andsimplicity.1) Speed: goCompilesquicklyandrunsefficiently, idealforlargeproject.2) Kecekapan: ITSComprehensivestandardlibraryraryrarexternaldependencies, enhingdevelyficiency.

Golang vs Python: Perbezaan dan Persamaan Utama Golang vs Python: Perbezaan dan Persamaan Utama Apr 17, 2025 am 12:15 AM

Golang dan Python masing -masing mempunyai kelebihan mereka sendiri: Golang sesuai untuk prestasi tinggi dan pengaturcaraan serentak, sementara Python sesuai untuk sains data dan pembangunan web. Golang terkenal dengan model keserasiannya dan prestasi yang cekap, sementara Python terkenal dengan sintaks ringkas dan ekosistem perpustakaan yang kaya.

Golang dan C: Perdagangan dalam prestasi Golang dan C: Perdagangan dalam prestasi Apr 17, 2025 am 12:18 AM

Perbezaan prestasi antara Golang dan C terutamanya ditunjukkan dalam pengurusan ingatan, pengoptimuman kompilasi dan kecekapan runtime. 1) Mekanisme pengumpulan sampah Golang adalah mudah tetapi boleh menjejaskan prestasi, 2) Pengurusan memori manual C dan pengoptimuman pengkompil lebih cekap dalam pengkomputeran rekursif.

Perlumbaan Prestasi: Golang vs C Perlumbaan Prestasi: Golang vs C Apr 16, 2025 am 12:07 AM

Golang dan C masing-masing mempunyai kelebihan sendiri dalam pertandingan prestasi: 1) Golang sesuai untuk kesesuaian tinggi dan perkembangan pesat, dan 2) C menyediakan prestasi yang lebih tinggi dan kawalan halus. Pemilihan harus berdasarkan keperluan projek dan tumpukan teknologi pasukan.

See all articles