parallel

README

Parallel utilities for golang

Please read parallel_for_test.go for examples.

Documentation

Index

• func For(n int, fn func(i int, total int) error) error
• type Future
  • func NewFuture(fn func() (interface{}, error)) *Future
  • func (fut *Future) Get() (interface{}, error)
  • func (fut *Future) IsComplete() bool
• type Notification
  • func NewNotification() *Notification
  • func (n *Notification) Done()
  • func (n *Notification) Wait()

Functions

func For

func For(n int, fn func(i int, total int) error) error

For will execute N goroutines, wait them complete, and gather errors.

The callback `fn` takes two parameters: the offset of goroutine and the total size of goroutines.

Types

type Future

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

func NewFuture

func NewFuture(fn func() (interface{}, error)) *Future

func (*Future) Get

func (fut *Future) Get() (interface{}, error)

func (*Future) IsComplete

func (fut *Future) IsComplete() bool

type Notification

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

func NewNotification

func NewNotification() *Notification

func (*Notification) Done

func (n *Notification) Done()

func (*Notification) Wait

func (n *Notification) Wait()