동시 프로그래밍에서 동기화는 데이터 경합을 방지하고 스레드 또는 고루틴이 조화로운 방식으로 작동하도록 하는 데 핵심입니다. 버퍼나 대기열과 같은 공유 리소스에 액세스하는 여러 생산자와 소비자를 조정하는 데 문제가 있다고 상상해 보세요. 이러한 고전적인 동시성 문제는 생산자-소비자 문제로 알려져 있습니다. 이 시나리오에서는 생산자가 데이터를 덮어쓰지 않고 소비자가 유효하지 않거나 오래된 데이터를 읽지 않도록 하기 위해 동기화가 필수적입니다. 적절한 동기화가 없으면 공유 데이터에 대한 동시 액세스로 인해 경쟁 조건, 데이터 손상 또는 충돌이 발생할 수 있으므로 동기화가 필요합니다. 버퍼가 가득 차면 생산자는 기다려야 하고, 버퍼가 비어 있으면 소비자는 기다려야 합니다. 고정된 크기의 제한된 버퍼가 있고 여러 생산자와 소비자 사이에서 이에 대한 액세스를 관리해야 하는 시나리오가 있을 수 있습니다.
Go의 sync.Cond는 특정 조건이 충족될 때까지 고루틴이 대기할 수 있도록 하는 신호 메커니즘입니다. 일부 고루틴이 실행을 일시 중지하고 다른 고루틴이 특정 작업을 완료할 때까지 기다려야 하는 복잡한 작업 흐름을 조정하는 데 특히 유용합니다. sync.Cond의 아이디어는 매우 간단하고 이해하기 쉽습니다.
고정된 크기의 버퍼(또는 대기열)가 있다고 상상해 보세요. 여러 생산자가 항목을 생성하여 버퍼에 추가하는 반면, 여러 소비자는 항목을 제거합니다. 과제는 다음과 같습니다.
초기 코드 구조는 다음과 같습니다.
package main
import (
"fmt"
"sync"
"time"
)
const bufferSize = 5
type Buffer struct {
data []int
mu sync.Mutex
cond *sync.Cond
}
func (b *Buffer) produce(item int) {
// Producer logic to add item to the buffer
}
func (b *Buffer) consume() int {
// Consumer logic to remove item from the buffer
return 0
}
func main() {
buffer := &Buffer{data: make([]int, 0, bufferSize)}
buffer.cond = sync.NewCond(&buffer.mu)
var wg sync.WaitGroup
// Start producer goroutines
for i := 1; i <= 3; i++ {
wg.Add(1)
go func(id int) {
defer wg.Done()
for j := 0; j < 5; j++ { // Each producer creates 5 items
buffer.produce(id*10 + j) // Produce unique items based on id and j
time.Sleep(100 * time.Millisecond)
}
}(i)
}
// Start consumer goroutines
for i := 1; i <= 3; i++ {
wg.Add(1)
go func(id int) {
defer wg.Done()
for j := 0; j < 5; j++ { // Each consumer consumes 5 items
item := buffer.consume()
fmt.Printf("Consumer %d consumed item %d\n", id, item)
time.Sleep(150 * time.Millisecond)
}
}(i)
}
wg.Wait()
fmt.Println("All producers and consumers finished.")
}
엔지니어로서 우리의 임무는 이러한 요구 사항을 달성하기 위한 생산 및 소비 방법을 구현하는 것입니다. 생산 메소드는 항목을 버퍼에 추가하고 항목이 추가되면 소비자에게 알립니다. Consume 메소드는 버퍼에서 항목을 제거하고 항목이 제거되면 생산자에게 알립니다. 이 문제는 버퍼가 가득 차거나 비어 있을 때 기다렸다가 신호를 보내는 sync.Cond를 사용하여 원활하게 해결될 수 있습니다.
다음은 생산 및 소비 방법에서 sync.Cond가 사용되는 방식에 대한 분석입니다.
초기화:
buffer.cond = sync.NewCond(&buffer.mu)
프로듀스 방식(프로듀스):
func (b *Buffer) produce(item int) {
b.mu.Lock()
defer b.mu.Unlock()
// Wait if the buffer is full
for len(b.data) == bufferSize {
b.cond.Wait() // Release lock and wait until signaled
}
// Add item to the buffer
b.data = append(b.data, item)
fmt.Printf("Produced item %d\n", item)
// Signal a consumer that an item is available
b.cond.Signal()
}
소비자 방식(소비):
func (b *Buffer) consume() int {
b.mu.Lock()
defer b.mu.Unlock()
// Wait if the buffer is empty
for len(b.data) == 0 {
b.cond.Wait() // Release lock and wait until signaled
}
// Remove item from the buffer
item := b.data[0]
b.data = b.data[1:]
fmt.Printf("Consumed item %d\n", item)
// Signal a producer that space is available
b.cond.Signal()
return item
}
이 예에서는:
이러한 조정을 통해 생산자와 소비자는 간섭이나 교착 상태 없이 버퍼를 공유할 수 있으며, 버퍼 상태에 따라 액세스를 효율적으로 관리할 수 있습니다.
다음과 같이 여러 고루틴이 특정 조건을 기다려야만 진행하는 작업이 있다고 상상해 보세요.
위 내용은 Go의 sync.Cond 이해: 생산자-소비자 시나리오에서 고루틴 동기화의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!
![[웹 프런트엔드] Node.js 빠른 시작](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
