b6a95a8cb3
* Dropped unused codekit config * Integrated dynamic and static bindata for public * Ignore public bindata * Add a general generate make task * Integrated flexible public assets into web command * Updated vendoring, added all missiong govendor deps * Made the linter happy with the bindata and dynamic code * Moved public bindata definition to modules directory * Ignoring the new bindata path now * Updated to the new public modules import path * Updated public bindata command and drop the new prefix
56 lines
1.3 KiB
Go
56 lines
1.3 KiB
Go
// Copyright 2012, Google Inc. All rights reserved.
|
|
// Use of this source code is governed by a BSD-style
|
|
// license that can be found in the LICENSE file.
|
|
|
|
package sync2
|
|
|
|
// What's in a name? Channels have all you need to emulate a counting
|
|
// semaphore with a boatload of extra functionality. However, in some
|
|
// cases, you just want a familiar API.
|
|
|
|
import (
|
|
"time"
|
|
)
|
|
|
|
// Semaphore is a counting semaphore with the option to
|
|
// specify a timeout.
|
|
type Semaphore struct {
|
|
slots chan struct{}
|
|
timeout time.Duration
|
|
}
|
|
|
|
// NewSemaphore creates a Semaphore. The count parameter must be a positive
|
|
// number. A timeout of zero means that there is no timeout.
|
|
func NewSemaphore(count int, timeout time.Duration) *Semaphore {
|
|
sem := &Semaphore{
|
|
slots: make(chan struct{}, count),
|
|
timeout: timeout,
|
|
}
|
|
for i := 0; i < count; i++ {
|
|
sem.slots <- struct{}{}
|
|
}
|
|
return sem
|
|
}
|
|
|
|
// Acquire returns true on successful acquisition, and
|
|
// false on a timeout.
|
|
func (sem *Semaphore) Acquire() bool {
|
|
if sem.timeout == 0 {
|
|
<-sem.slots
|
|
return true
|
|
}
|
|
select {
|
|
case <-sem.slots:
|
|
return true
|
|
case <-time.After(sem.timeout):
|
|
return false
|
|
}
|
|
}
|
|
|
|
// Release releases the acquired semaphore. You must
|
|
// not release more than the number of semaphores you've
|
|
// acquired.
|
|
func (sem *Semaphore) Release() {
|
|
sem.slots <- struct{}{}
|
|
}
|