Go语言---并发编程之channel(双channel,单channel)以及应用实例(生产者消费者、打印机模型)
在Go语言中,通过channel可以实现并发编程中的协程(goroutine)间的同步和数据通信。下面是一些常见的使用场景和代码示例:
- 生产者-消费者模型(单channel)
生产者-消费者模型是一种常见的并发模式,在这种模式中,生产者负责生产数据,消费者负责处理数据。通过channel可以实现两者之间的同步。
package main
import (
"fmt"
"sync"
"time"
)
func producer(queue chan<- int, wg *sync.WaitGroup) {
defer wg.Done()
for i := 0; i < 10; i++ {
queue <- i
time.Sleep(time.Millisecond * 500)
}
close(queue)
}
func consumer(queue <-chan int, wg *sync.WaitGroup) {
defer wg.Done()
for {
num, ok := <-queue
if !ok {
break
}
fmt.Println("Processing:", num)
}
}
func main() {
var wg sync.WaitGroup
queue := make(chan int, 1)
wg.Add(1)
go producer(queue, &wg)
wg.Add(1)
go consumer(queue, &wg)
wg.Wait()
}
- 双channel(双生产者-单消费者模型)
双channel是指有两个并发的生产者和一个消费者。
package main
import (
"fmt"
"sync"
"time"
)
func producer1(queue chan<- int, wg *sync.WaitGroup) {
defer wg.Done()
for i := 0; i < 10; i++ {
queue <- i
time.Sleep(time.Millisecond * 500)
}
}
func producer2(queue chan<- int, wg *sync.WaitGroup) {
defer wg.Done()
for i := 0; i < 10; i++ {
queue <- i * 2
time.Sleep(time.Millisecond * 500)
}
}
func consumer(queue1 <-chan int, queue2 <-chan int, wg *sync.WaitGroup) {
defer wg.Done()
for {
select {
case num1, ok := <-queue1:
if !ok {
break
}
fmt.Println("Processing from queue1:", num1)
case num2, ok := <-queue2:
if !ok {
break
}
fmt.Println("Processing from queue2:", num2)
}
}
}
func main() {
var wg sync.WaitGroup
queue1 := make(chan int, 1)
queue2 := make(chan int, 1)
wg.Add(1)
go producer1(queue1, &wg)
wg.Add(1)
go producer2(queue2, &wg)
wg.Add(1)
go consumer(queue1, queue2, &wg)
wg.Wait()
}
以上代码展示了如何使用Go语言的channel实现生产者-消费者模型和双生产者-单消费者模型。在实际应用中,可以根据具体需求调整代码。
评论已关闭