Worker pool iskeleti

Worker pool yapısını ve channel'ları tasarlarsın.

Proje: worker pool

Bu projede dosya boyutlarını hesaplayan bir iş havuzu kuracaksın. Bir worker pool üç parçadan oluşur: iş kanalı (yapılacaklar), sabit sayıda işçi (goroutine) ve sonuç kanalı.

isler   := make(chan Is)
sonuclar := make(chan Sonuc)
for w := 1; w <= 3; w++ {
    go isci(w, isler, sonuclar)
}

İşçi sayısını sabit tutmak, binlerce iş olsa bile kaynak kullanımını öngörülebilir kılar.

Türleri tanımla

Önce iş ve sonuç türleri yazılır; kanallar bu türleri taşır:

type Is struct {
    ID  int
    Yol string
}

type Sonuc struct {
    IsID  int
    Boyut int64
    Hata  error
}

Sonucun içinde hata alanı bulunması, bir işin başarısız olmasının tüm havuzu durdurmamasını sağlar.

Uygulama Havuz iskeleti

Is ve Sonuc türlerini tanımla. isci(isler <-chan Is, sonuclar chan<- Sonuc) her iş için Sonuc{IsID: is.ID, Boyut: int64(len(is.Yol))} göndersin. Tek işçiyle Is{1, "a.txt"} işini çalıştırıp sonucun Boyut alanını yazdır.

Örnek çözümü göster

package main

import "fmt"

type Is struct {
    ID  int
    Yol string
}

type Sonuc struct {
    IsID  int
    Boyut int64
    Hata  error
}

func isci(isler <-chan Is, sonuclar chan<- Sonuc) {
    for is := range isler {
        sonuclar <- Sonuc{IsID: is.ID, Boyut: int64(len(is.Yol))}
    }
}

func main() {
    isler := make(chan Is, 1)
    sonuclar := make(chan Sonuc, 1)
    go isci(isler, sonuclar)
    isler <- Is{1, "a.txt"}
    close(isler)
    fmt.Println((<-sonuclar).Boyut)
}

Kendini test et

Neden her iş için ayrı goroutine açmak yerine havuz kullanılır?
- Goroutine açmak yasak olduğu için
- Kanallar yalnızca havuzda çalıştığı için
- GC'yi kapatmak için
- Eşzamanlı iş sayısını (dosya tanıtıcısı, bağlantı) sınırlamak için
Cevabı göster

Eşzamanlı iş sayısını (dosya tanıtıcısı, bağlantı) sınırlamak için — Goroutine ucuzdur ama her iş dosya açıyor ya da istek atıyorsa sınırsız eşzamanlılık sistem kaynaklarını tüketir.

Yalnızca okuma kanalı

func isci(id int, isler ____ Is, sonuclar chan<- Sonuc) {

Cevabı göster

func isci(id int, isler <-chan Is, sonuclar chan<- Sonuc) {

Havuz parçası

isler

Yapılacak işler
isci

Sabit sayıda goroutine
sonuclar

Çıktılar
Sonuc.Hata

İş bazında hata

Sıradaki ders: İş kuyruğu

Deneyiminizi Geliştiriyoruz

Çerez Tercihleri

Kesinlikle Gerekli Çerezler

Analitik Çerezler