Go語(yǔ)言并發(fā)編程如何實(shí)現(xiàn)任務(wù)并行

小樊
82
2024-10-25 06:08:56

在Go語(yǔ)言中，可以使用goroutines和channels來(lái)實(shí)現(xiàn)任務(wù)并行。goroutines是Go語(yǔ)言的輕量級(jí)線程，可以并發(fā)執(zhí)行多個(gè)任務(wù)。channels則用于在goroutines之間傳遞數(shù)據(jù)，實(shí)現(xiàn)同步和通信。

以下是一個(gè)簡(jiǎn)單的示例，展示了如何使用goroutines和channels實(shí)現(xiàn)任務(wù)并行：

package main

import (
 "fmt"
 "time"
)

func worker(id int, jobs <-chan int, results chan<- int) {
 for j := range jobs {
 fmt.Printf("Worker %d started job %d\n", id, j)
 time.Sleep(time.Second) // 模擬任務(wù)執(zhí)行時(shí)間
 fmt.Printf("Worker %d finished job %d\n", id, j)
 results <- j * 2
 }
}

func main() {
 const numJobs = 5
 jobs := make(chan int, numJobs)
 results := make(chan int, numJobs)

 // 創(chuàng)建5個(gè)goroutines來(lái)處理任務(wù)
 for w := 1; w <= 3; w++ {
 go worker(w, jobs, results)
 }

 // 將任務(wù)發(fā)送到j(luò)obs通道
 for j := 1; j <= numJobs; j++ {
 jobs <- j
 }
 close(jobs)

 // 收集并打印任務(wù)結(jié)果
 for a := 1; a <= numJobs; a++ {
 <-results
 }
}

在上面的示例中，我們定義了一個(gè)worker函數(shù)，它接受一個(gè)ID、一個(gè)任務(wù)通道和一個(gè)結(jié)果通道作為參數(shù)。worker函數(shù)從任務(wù)通道中讀取任務(wù)，模擬任務(wù)執(zhí)行時(shí)間，然后將結(jié)果發(fā)送到結(jié)果通道。

在main函數(shù)中，我們創(chuàng)建了5個(gè)goroutines來(lái)處理任務(wù)，并將它們啟動(dòng)。然后，我們將5個(gè)任務(wù)發(fā)送到jobs通道。接下來(lái)，我們關(guān)閉jobs通道，表示沒(méi)有更多的任務(wù)需要處理。最后，我們從結(jié)果通道中讀取并打印任務(wù)結(jié)果。

運(yùn)行上述代碼，你將看到5個(gè)任務(wù)并行執(zhí)行的情況。每個(gè)任務(wù)都由一個(gè)goroutine處理，它們之間通過(guò)jobs和results通道進(jìn)行通信和同步。

這只是一個(gè)簡(jiǎn)單的示例，你可以根據(jù)自己的需求進(jìn)行擴(kuò)展和修改。Go語(yǔ)言提供了豐富的并發(fā)編程工具和庫(kù)，可以幫助你更高效地實(shí)現(xiàn)任務(wù)并行。

0 踩