Ketahui model pengaturcaraan serentak dalam bahasa Go dan laksanakan ringkasan hasil tugas pengkomputeran teragih?

Ketahui model pengaturcaraan serentak dalam bahasa Go dan laksanakan ringkasan hasil tugasan pengkomputeran teragih

Bahasa Go ialah bahasa pengaturcaraan yang cekap dan serentak yang sangat berkuasa apabila menangani tugasan serentak. Dengan menggunakan ciri konkurensi yang disediakan oleh bahasa Go, kami boleh membina sistem pengkomputeran teragih dengan mudah, mengagihkan tugas pengkomputeran kepada berbilang nod dan meringkaskan hasil pengiraan setiap nod.

Pertama, kita perlu memahami model pengaturcaraan serentak dalam bahasa Go. Bahasa Go melaksanakan konkurensi melalui gorout dan saluran. Goroutine ialah benang ringan yang boleh menjalankan berbilang tugas secara serentak dalam persekitaran masa jalan bahasa Go. Saluran ialah mekanisme untuk komunikasi antara gorouti, yang boleh digunakan untuk memindahkan data antara gorouti.

Seterusnya, kami akan menggunakan ciri konkurensi bahasa Go untuk melaksanakan contoh ringkasan hasil mudah tugas pengkomputeran teragih. Katakan kita mempunyai tugas yang memerlukan pengiraan, agihkan tugas ini kepada berbilang nod dan kumpulkan hasilnya.

Mula-mula, kami mentakrifkan struktur Tugasan untuk mewakili tugasan yang akan dikira:

type Task struct {
    ID     int
    Params []int
    Result int
}

Kemudian, kami mentakrifkan kalk fungsi untuk mengira tugasan:

func calc(task Task) Task {
    // 进行计算
    // ...
    task.Result = // 计算结果
    return task
}

Seterusnya, kami mentakrifkan pekerja fungsi untuk memproses tugas setiap nod Pengkomputeran tugasan:

func worker(tasks <-chan Task, results chan<- Task) {
    for {
        task, ok := <-tasks
        if !ok {
            break
        }
        
        result := calc(task)
        result.ID = task.ID
        results <- result
    }
}

Dalam fungsi utama, kita boleh mencipta berbilang proses pekerja untuk memproses tugas, dan menggunakan saluran untuk memindahkan tugas dan hasil:

func main() {
    tasks := make(chan Task, 100)
    results := make(chan Task, 100)

    // 创建worker并启动
    for i := 0; i < runtime.NumCPU(); i++ {
        go worker(tasks, results)
    }

    // 分发任务
    for i := 0; i < 10; i++ {
        task := Task{
            ID:     i,
            Params: // 任务参数
        }
        tasks <- task
    }
    close(tasks)

    // 收集结果
    for i := 0; i < 10; i++ {
        result := <-results
        // 处理结果
        // ...
    }
}

Kod di atas mencipta pelbagai proses pekerja dan menggunakan saluran pemindahan tugas dan keputusan ringkasan keputusan tugas pengkomputeran teragih.

Dalam aplikasi praktikal, kami boleh mengembangkan lagi nod kepada berbilang hos dan berkomunikasi melalui rangkaian untuk mencapai pengkomputeran teragih sebenar. Pada masa yang sama, kami juga boleh menggunakan ciri konkurensi lain yang disediakan oleh bahasa Go, seperti mutex (Mutex) dan pembolehubah keadaan (Cond), untuk menyelesaikan masalah konkurensi yang lebih kompleks.

Dengan mempelajari model pengaturcaraan serentak dalam bahasa Go dan mempraktikkan contoh ringkasan keputusan tugasan pengkomputeran teragih, kami dapat mengatasi cabaran pengkomputeran serentak dengan lebih baik dan menyediakan penyelesaian yang lebih cekap untuk pembangunan projek sebenar.

Atas ialah kandungan terperinci Ketahui model pengaturcaraan serentak dalam bahasa Go dan laksanakan ringkasan hasil tugas pengkomputeran teragih?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!