pool

Documentation

Index

• type Walk
  • func (p *Walk) Error() error
  • func (p *Walk) TrySetError(err error)
  • func (p *Walk) Wait()
  • func (p *Walk) Walk(ctx context.Context, taskChan <-chan interface{}, procFn WalkFunc)
• type WalkFunc

Examples

• Walk

Types

type Walk

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

Example

package main

import (
	"context"
	"fmt"

	"github.com/searKing/golang/go/x/pool"
)

func main() {

	// chan WalkInfo
	walkChan := make(chan interface{}, 0)

	p := pool.Walk{}
	defer p.Wait()

	p.Walk(context.Background(), walkChan, func(name interface{}) error {
		fmt.Printf("%s\n", name)
		return nil
	})

	walkChan <- "1"
	walkChan <- "2"
	walkChan <- "3"
	walkChan <- "4"
	walkChan <- "5"
	close(walkChan)
	// Output Like:
	// 1
	// 2
	// 3
	// 4
	// 5
}

func (*Walk) Error

func (p *Walk) Error() error

func (*Walk) TrySetError

func (p *Walk) TrySetError(err error)

func (*Walk) Wait

func (p *Walk) Wait()

Wait blocks until the WaitGroup counter is zero.

func (*Walk) Walk

func (p *Walk) Walk(ctx context.Context, taskChan <-chan interface{}, procFn WalkFunc)

Walk will consume all tasks parallel and block until ctx.Done() or taskChan is closed.

type WalkFunc

type WalkFunc func(task interface{}) error

WalkFunc is the type of the function called for each task processed by Walk. The path argument contains the argument to Walk as a task.

In the case of an error, the info argument will be nil. If an error is returned, processing stops.