gosem

gosem

gosem provides multiple semaphore functions. Currently supports inmemory, redis implementation.

Example

// You can set a number of available resources.
var sem = gosem.NewSemaphore(3)

func main() {
  for _, task := range tasks {
    // Do task if available resources exists.
    sem.Acquire()
    go func(task Task) {
      defer sem.Release()
      do(task)
    }(task)
  }
}

Features

Memory-based semaphore

Simple semaphore

Semaphore is a semaphore that can be used to coordinate the number of accessing shared data from multiple goroutine.

sem := gosem.NewSemaphore(5)
// acquire a new resource
sem.Acquire()
// release the resource
sem.Release()

Time semaphore

TimeSemaphore is a semaphore that can be used to coordinate the number of accessing shared data from multiple goroutine with specified time.

sem := gosem.NewTimeSemaphore(5, time.Second)
// acquire a new resource
sem.Acquire()
// release the resource
sem.Release()

Redis-based semaphore

Implements a semaphore using Redis.

It can be used between processes that are on the multiple host.

Counting semaphore

import "gopkg.in/redis.v3"

client := redis.NewClient(
  &redis.Options{Network: "tcp", Addr: "127.0.0.1:6379"},
)
sem := gosem.NewRedisSemaphore(client, 5)
// acquire a new resource
sem.Acquire()
// release the resource
sem.Release()

Contribution

1. Fork (https://github.com/bluele/gosem/fork)
2. Create a feature branch
3. Commit your changes
4. Rebase your local changes against the master branch
5. Run test suite with the go test ./... command and confirm that it passes
6. Run gofmt -s
7. Create new Pull Request

Author

Jun Kimura

• http://github.com/bluele
• junkxdev@gmail.com