在 Linux 下,使用 Golang 进行并发编程主要依赖于 goroutines 和 channels。goroutines 是轻量级的线程,可以在程序中同时运行多个任务。channels 用于在 goroutines 之间传递数据。以下是一些使用 Golang 进行并发编程的基本概念和示例:
- 创建 goroutine:
要创建一个 goroutine,只需在函数调用前加上关键字 go
。例如:
package main import ( "fmt" "time" ) func printNumbers() { for i := 1; i <= 5; i++ { fmt.Printf("Number: %d\n", i) time.Sleep(1 * time.Second) } } func main() { go printNumbers() time.Sleep(6 * time.Second) }
在这个例子中,我们创建了一个名为 printNumbers
的函数,它会打印数字 1 到 5,每次打印之间暂停 1 秒。在 main
函数中,我们使用 go
关键字创建了一个新的 goroutine 来运行 printNumbers
函数。
- 使用 channels:
channels 用于在 goroutines 之间传递数据。要创建一个 channel,可以使用 make
函数:
ch := make(chan int)
要在 goroutine 之间发送和接收数据,可以使用 <-
操作符:
// 发送数据到 channel ch <- 42 // 从 channel 接收数据 value := <-ch
以下是一个使用 channels 的示例:
package main import ( "fmt" "time" ) func printNumbers(ch chan int) { for i := 1; i <= 5; i++ { ch <- i time.Sleep(1 * time.Second) } close(ch) } func main() { ch := make(chan int) go printNumbers(ch) for num := range ch { fmt.Printf("Received number: %d\n", num) } }
在这个例子中,我们创建了一个名为 printNumbers
的函数,它接收一个整数类型的 channel 作为参数。函数内部,我们使用 <-
操作符将数字发送到 channel。在 main
函数中,我们创建了一个 channel,并将其传递给 printNumbers
函数。然后我们使用 for
循环和 range
关键字从 channel 接收数据并打印。
这些是 Golang 并发编程的基本概念。你可以根据需要组合和扩展这些概念来实现更复杂的并发任务。