semaphore

README

concurrent

concurrent utils for golang

peference

// concurrent.semaphore
BenchmarkSemaphore(TryAcquire()&&Release())				20000000	89.6 ns/op
BenchmarkSemaphoreConcurrent(TryAcquire()&&Release())	20000000	89.9 ns/op
	

usage

package main
import(
    "fmt"
    "time"

    nsema "github.com/niean/gotools/concurrent/semaphore"
)

func main(){
    // init sema
    concurrentNum := 2 // 5,10..
    sema := nsema.NewSemaphore(concurrentNum)

    // use sema
    for i:=0; i<100; i++ {
        go func(num int){
            if !sema.TryAcquire() {
                fmt.Printf("%d, get sema, fail\n", num)
                return
            }
            defer sema.Release()

            time.Sleep(1*time.Nanosecond)
            fmt.Printf("%d, get sema, ok\n", num)
        }(i)
    }

    // keep alive
    time.Sleep(2*time.Second)
}

reference

TODO

Documentation

Index

• type Semaphore
  • func NewSemaphore(concurrencyNum int) *Semaphore
  • func (this *Semaphore) Acquire()
  • func (this *Semaphore) AvailablePermits() int
  • func (this *Semaphore) Release()
  • func (this *Semaphore) TryAcquire() bool

Types

type Semaphore

type Semaphore struct {
	// contains filtered or unexported fields
}

func NewSemaphore

func NewSemaphore(concurrencyNum int) *Semaphore

func (*Semaphore) Acquire

func (this *Semaphore) Acquire()

func (*Semaphore) AvailablePermits

func (this *Semaphore) AvailablePermits() int

func (*Semaphore) Release

func (this *Semaphore) Release()

func (*Semaphore) TryAcquire

func (this *Semaphore) TryAcquire() bool