Help us shape the future of Go! Take the 2026 Go Developer Survey

safe

package
v1.7.19 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 28, 2019 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Go 

func Go(goroutine func())

Go starts a recoverable goroutine

func GoWithRecover 

func GoWithRecover(goroutine func(), customRecover func(err interface{}))

GoWithRecover starts a recoverable goroutine using given customRecover() function

func OperationWithRecover added in v1.1.2 

func OperationWithRecover(operation backoff.Operation) backoff.Operation

OperationWithRecover wrap a backoff operation in a Recover

Types

type Pool 

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

Pool is a pool of go routines

func NewPool added in v1.1.0 

func NewPool(parentCtx context.Context) *Pool

NewPool creates a Pool

func (*Pool) AddGoCtx added in v1.1.0 

func (p *Pool) AddGoCtx(goroutine routineCtx)

AddGoCtx adds a recoverable goroutine with a context without starting it

func (*Pool) Cleanup added in v1.2.0 

func (p *Pool) Cleanup()

Cleanup releases resources used by the pool, and should be called when the pool will no longer be used

func (*Pool) Ctx added in v1.1.0 

func (p *Pool) Ctx() context.Context

Ctx returns main context

func (*Pool) Go 

func (p *Pool) Go(goroutine func(stop chan bool))

Go starts a recoverable goroutine, and can be stopped with stop chan

func (*Pool) GoCtx added in v1.1.0 

func (p *Pool) GoCtx(goroutine routineCtx)

GoCtx starts a recoverable goroutine with a context

func (*Pool) Start added in v1.1.0 

func (p *Pool) Start()

Start starts all stopped routines

func (*Pool) Stop 

func (p *Pool) Stop()

Stop stops all started routines, waiting for their termination

type Safe 

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

Safe contains a thread-safe value

func New 

func New(value interface{}) *Safe

New create a new Safe instance given a value

func (*Safe) Get 

func (s *Safe) Get() interface{}

Get returns the value

func (*Safe) Set 

func (s *Safe) Set(value interface{})

Set sets a new value

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.