semaphore

README

semaphore

POSIX semaphore library for Golang

Usage

package main

import (
	"log"
	"time"

	"github.com/zzhaolei/semaphore"
)

func main() {
	name := "test"
	mode := 0o644
	value := 2

	s := semaphore.New()
	if err := s.Open(name, mode, value); err != nil {
		log.Fatal(err)
	}

	log.Println("acquire...")
	s.Acquire()
	// if err := s.TryAcquire(); err != nil {
	// 	log.Fatal(err)
	// }

	log.Println("running...")
	time.Sleep(time.Second * 5)

	s.Release()
	log.Println("release")

	s.Unlink("test")
	log.Println("close and unlink")
}

Documentation

Index

• type Semaphore
  • func New() *Semaphore
  • func (sem *Semaphore) Acquire()
  • func (sem *Semaphore) Open(name string, mode int, value int) error
  • func (sem *Semaphore) Release()
  • func (sem *Semaphore) TryAcquire() error
  • func (sem *Semaphore) Unlink(name string)

Types

type Semaphore

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

func New

func New() *Semaphore

func (*Semaphore) Acquire

func (sem *Semaphore) Acquire()

func (*Semaphore) Open

func (sem *Semaphore) Open(name string, mode int, value int) error

func (*Semaphore) Release

func (sem *Semaphore) Release()

func (*Semaphore) TryAcquire

func (sem *Semaphore) TryAcquire() error

func (*Semaphore) Unlink

func (sem *Semaphore) Unlink(name string)