Go에서 Deadline으로 잠금 획득
Go에서 sync.Mutex 유형은 Lock() 및 Unlock() 메서드만 제공합니다. 잠금 획득을 기한 내에 시도해야 하거나 잠재적으로 즉시 중단해야 하는 시나리오의 경우 기본 제공 솔루션이 없습니다.
제안 솔루션: 채널을 뮤텍스로
또 다른 접근 방식은 버퍼 크기가 1인 채널을 사용하여 뮤텍스를 시뮬레이션하는 것입니다. 단일 빈 구조체 값(struct{}{})을 보내고 받으면 잠금 및 잠금 해제 작업을 수행할 수 있습니다.
잠금:
<code class="go">l := make(chan struct{}, 1) l <- struct{}{}</code>
잠금 해제:
<code class="go"><-l</code>
잠금 시도:
<code class="go">select { case l <- struct{}{}: // lock acquired <-l default: // lock not acquired }</code>
시간 초과로 잠금 시도:
<code class="go">select { case l <- struct{}{}: // lock acquired <-l case <-time.After(time.Minute): // lock not acquired }</code>
제공된 예제에서 s.someObj는 키에서 값으로의 매핑으로 가정됩니다.
예 1: 지연 시간에 민감한 코드에 대한 LockBefore()
<code class="go">// DoTheThing locks before performing expensive computations. func (s *RPCService) DoTheThing(ctx context.Context, ...) ... { l := make(chan struct{}, 1) select { case l <- struct{}{}: defer <-l ... expensive computation based on internal state ... default: return s.cheapCachedResponse[req.Parameter] } }</code>
예 2: 통계 업데이트를 위한 TryLock()
<code class="go">// updateObjStats attempts to lock and update stats. func (s *StatsObject) updateObjStats(key, value interface{}) { l := make(chan struct{}, 1) select { case l <- struct{}{}: defer <-l ... update stats ... ... fill in s.cheapCachedResponse ... default: // skip locked object } } // UpdateStats attempts to lock and update stats for all objects. func (s *StatsObject) UpdateStats() { s.someObj.Range(s.updateObjStats) }</code>
위 내용은 Go에서 기한 내에 잠금을 획득하는 방법은 무엇입니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!