Golang并发编程如何实现

在Golang中，并发编程主要通过goroutines和channels来实现。Goroutines是轻量级的线程，可以在一个操作系统线程上并发执行多个任务。Channels则用于在不同的goroutines之间传递数据。

下面是一个简单的示例，展示了如何使用goroutines和channels实现并发编程：

package main

import (
	"fmt"
	"sync"
)

func worker(id int, wg *sync.WaitGroup, jobs <-chan int, results chan<- int) {
	defer wg.Done()

	for job := range jobs {
		fmt.Printf("Worker %d started job %d\n", id, job)
		results <- job * 2
		fmt.Printf("Worker %d finished job %d\n", id, job)
	}
}

func main() {
	const numJobs = 10
	const numWorkers = 3

	jobs := make(chan int, numJobs)
	results := make(chan int, numJobs)

	var wg sync.WaitGroup
	wg.Add(numWorkers)

	for i := 0; i < numWorkers; i++ {
		go worker(i, &wg, jobs, results)
	}

	for i := 0; i < numJobs; i++ {
		jobs <- i
	}
	close(jobs)

	wg.Wait()
	close(results)

	for result := range results {
		fmt.Println("Result:", result)
	}
}

在这个示例中，我们创建了一个名为worker的函数，它接收一个整数作为输入，并将其乘以2作为结果返回。我们创建了3个工作线程（goroutines），它们从jobs通道中读取任务，并将结果写入results通道。

在main函数中，我们创建了jobs和results通道，然后启动了3个工作线程。接着，我们将10个任务发送到jobs通道。最后，我们等待所有工作线程完成任务，并关闭results通道。在这个过程中，我们可以看到任务是如何在不同的工作线程之间并发执行的。