Go語(yǔ)言條件變量怎樣避免忙等

小樊
81
2024-11-02 16:28:30

在Go語(yǔ)言中，為了避免忙等（busy waiting），我們可以使用sync.Cond來(lái)實(shí)現(xiàn)條件變量。sync.Cond是一個(gè)基于sync.Mutex的條件變量，它允許我們?cè)谔囟l件下等待，同時(shí)釋放互斥鎖，讓其他goroutine繼續(xù)執(zhí)行。當(dāng)條件滿足時(shí)，sync.Cond會(huì)自動(dòng)喚醒等待的goroutine。

下面是一個(gè)使用sync.Cond避免忙等的示例：

package main

import (
	"fmt"
	"sync"
	"time"
)

type Data struct {
	value int
	cond  *sync.Cond
}

func NewData() *Data {
	return &Data{
		cond: sync.NewCond(&sync.Mutex{}),
	}
}

func (d *Data) WaitForValue(target int) {
	d.cond.L.Lock() // 獲取互斥鎖
	for d.value != target {
		d.cond.Wait() // 等待條件滿足
	}
	fmt.Println("Condition met:", d.value)
	d.cond.L.Unlock() // 釋放互斥鎖
}

func (d *Data) SetValue(value int) {
	d.cond.L.Lock() // 獲取互斥鎖
	d.value = value
	d.cond.Signal() // 喚醒等待的goroutine
	d.cond.L.Unlock() // 釋放互斥鎖
}

func main() {
	data := NewData()

	go func() {
		time.Sleep(2 * time.Second) // 模擬一些初始化工作
		data.SetValue(10)
	}()

	data.WaitForValue(10)
}

在這個(gè)示例中，我們創(chuàng)建了一個(gè)Data結(jié)構(gòu)體，它包含一個(gè)整數(shù)值和一個(gè)條件變量。WaitForValue方法用于等待條件滿足，SetValue方法用于設(shè)置條件值并喚醒等待的goroutine。通過(guò)使用sync.Cond，我們可以避免忙等，因?yàn)?code>cond.Wait()會(huì)自動(dòng)釋放互斥鎖，讓其他goroutine繼續(xù)執(zhí)行。當(dāng)條件滿足時(shí)，sync.Cond會(huì)自動(dòng)喚醒等待的goroutine。

0 踩