채널을 사용하여 Go에서 시간 초과 잠금을 구현하는 방법은 무엇입니까?

Go에서 시간 제한으로 잠금

도전 과제:

Go에서 잠금을 획득하는 것은 특히 대기 시간을 처리할 때 문제가 될 수 있습니다. 민감한 작업. sync.Mutex 인터페이스는 조건부로 또는 지정된 기간 내에 잠금을 획득하는 기능 없이 기본 잠금 및 잠금 해제 기능만 제공합니다.

해결책:

채널을 뮤텍스로 사용:

간단하고 효과적인 해결책은 채널을 상호 배제 기본 요소로 활용하는 것입니다. 버퍼 크기가 1인 채널을 생성하면 잠금을 시뮬레이션할 수 있습니다.

<code class="go">l := make(chan struct{}, 1)</code>

잠금:

잠금을 획득하려면 채널:

<code class="go">l <- struct{}{}</code>

잠금 해제:

잠금을 해제하려면 다음 채널에서 수신하세요.

<code class="go"><-l</code>

잠금 시도:

시간 제한을 두고 잠금을 시도하려면 select 문을 사용하세요.

<code class="go">select {
case l <- struct{}{}:
    // lock acquired
    <-l
default:
    // lock not acquired
}</code>

이 접근 방식을 time.After()와 결합하면 마감 기한이 있는 TryLock을 구현할 수 있습니다.

<code class="go">select {
case l <- struct{}{}:
    // lock acquired
    <-l
case <-time.After(time.Minute):
    // lock not acquired
}</code>

예 1: 지연 시간에 민감한 작업 제한

<code class="go">func (s *RPCService) DoTheThing(ctx context.Context, ...) ... {
  if AcquireLock(ctx.Deadline(), &s.someObj[req.Parameter].lock) {
    defer ReleaseLock(&s.someObj[req.Parameter].lock)
    ... expensive computation ...
  } else {
    return s.cheapCachedResponse[req.Parameter]
  }
}</code>

예 2: 시간 초과로 통계 업데이트

<code class="go">func (s *StatsObject) updateObjStats(key, value interface{}) {
  if AcquireLock(200*time.Millisecond, &s.someObj[key].lock) {
    defer ReleaseLock(&s.someObj[key].lock)
    ... update stats ...
    ... fill in s.cheapCachedResponse ...
  }
}

func (s *StatsObject) UpdateStats() {
  s.someObj.Range(s.updateObjStats)
}</code>

이 접근 방식을 사용하면 조건부로 잠금을 획득하는 동시에 성능 및 리소스 활용 문제를 효과적으로 처리할 수 있습니다.

위 내용은 채널을 사용하여 Go에서 시간 초과 잠금을 구현하는 방법은 무엇입니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!