golang控制并发

Golang中的并发控制可以通过sync.WaitGroup来实现。WaitGroup对象内部有一个计数器，最初从0开始，它有三个方法：Add(), Done(), Wait()用来控制计数器的数量。下面示例代码中wg.Wait会阻塞代码的运行，直到计数器值为0 。

Golang并发编程实例实现高效率的任务调度

在现代计算机系统中，任务调度是一个关键的组成部分，它负责管理和分配计算机资源，以便有效地执行各种任务，在许多情况下，需要同时处理多个任务，而这就需要使用高效的任务调度算法来确保任务的正确执行，本文将介绍如何使用Golang进行并发编程，以实现高效率的任务调度，我们将通过一个实例来演示如何使用Golang的goroutine和channel来实现任务调度。

goroutine

goroutine是Golang中的轻量级线程，它是在Go语言运行时(runtime)中实现的，与操作系统线程相比，goroutine具有更小的内存开销和更低的创建和销毁成本，在高并发场景下，使用goroutine可以提高系统的性能和响应速度。

要创建一个goroutine,可以使用go关键字 followed by the function to be executed in the goroutine.

func printNumbers() {
    for i := 1; i <= 10; i++ {
        fmt.Println(i)
    }
}
func main() {
    go printNumbers() // 创建一个新的goroutine并执行printNumbers函数
    fmt.Println("Hello, World!") // 主线程继续执行其他任务
}

channel

channel是Golang中用于在不同goroutine之间传递数据的同步机制，它是一个无缓冲的通道，可以在发送和接收操作之间进行通信，当一个goroutine向通道发送数据时，另一个goroutine可以等待该数据的到来，这样，我们可以通过channel来实现任务之间的同步和通信。

下面是一个使用channel实现任务调度的例子：

package main
import (
    "fmt"
    "time"
)
func worker(id int, jobs <-chan int, results chan<int) {
    for j := range jobs {
        fmt.Printf("Worker %d processing job %d
", id, j)
        time.Sleep(time.Second) // 模拟耗时操作
        results <j * 2 // 将结果发送回主线程
    }
}
func main() {
    const numJobs = 5
    jobs := make(chan int, numJobs) // 创建一个有容量为numJobs的通道
    results := make(chan int, numJobs) // 创建一个有容量为numJobs的通道
    // 启动3个goroutine来执行worker函数
    for w := 1; w <= 3; w++ {
        go worker(w, jobs, results)
    }
    fmt.Println("Main thread sending jobs...")
    for j := 1; j <= numJobs; j++ {
        jobs <j // 将任务发送到jobs通道
    }
 close(jobs) // 关闭jobs通道，表示没有更多的任务了
    fmt.Println("Waiting for results...")
    for a := 1; a <= numJobs; a++ {
        fmt.Printf("%d ", <-results) // 从results通道接收并打印结果
    }
}

在这个例子中，我们创建了一个名为worker的函数，它接收一个整数id作为标识符，一个整数类型的通道jobs,以及一个整数类型的通道results。worker函数从jobs通道中读取任务，执行相应的操作，然后将结果发送到results通道，在main函数中，我们创建了两个通道jobs和results,并启动了3个goroutine来执行worker函数，我们向jobs通道发送任务，并等待所有任务完成，我们从results通道接收并打印结果。