concurrent

Documentation

Index

• func ExecuteTimeoutTask(f func() interface{}, duration time.Duration) (interface{}, error)
• type CountDownLatch
  • func NewCountDownLatch(num int) CountDownLatch

Functions

func ExecuteTimeoutTask

func ExecuteTimeoutTask(f func() interface{}, duration time.Duration) (interface{}, error)

Types

type CountDownLatch

type CountDownLatch interface {
	Cancel()
	WaitTimeout(duration time.Duration) bool
	Wait()
	Done()
	IsAlive() bool
}

func NewCountDownLatch

func NewCountDownLatch(num int) CountDownLatch