futures

package

v0.0.0-...-8eb2345 Latest Latest Go to latest Published: Apr 29, 2015 License: BSD-3-Clause Imports: 2 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Package futures emulates Python's concurrent.futures package as well as is possible with Go's lack of parametric types.

This section is empty.

This section is empty.

This section is empty.

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

Maintains the pool of workers and receives new work.

func NewExecutor(maxWorkers int) *Executor

Create a new Executor that does up to maxWorkers tasks in parallel.

func (me *Executor) Map(fn func(interface{}) interface{}, inputs <-chan interface{}) <-chan interface{}

Calls fn with each item received from inputs, and outputs the results in the same order to the returned channel.

func (me *Executor) Shutdown()

Prevents new tasks being submitted, and cleans up workers when all futures have been processed.

func (me *Executor) Submit(fn func() interface{}) *Future

Submit the function to the Executor, returning a Future that represents it.

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

Represents some asynchronous execution.

func (me *Future) Result() interface{}

Blocks until the Future completes, and returns the computed value.