cocurrent

README

Cocurrent - A Simple Goroutine Limit Pool

Installation

To install the package, run:

go get github.com/go-zoox/cocurrent

Getting Started

func TestCocurrent(t *testing.T) {
	c := New(2)

	for i := 0; i < 4; i++ {
		fmt.Println("Adding task", i)
		c.Add(func(args ...interface{}) {
			index := args[0].(int)

			fmt.Println("task", index, time.Now())
			time.Sleep(3 * time.Second)

			if index == 0 {
				panic("panic error for task 0")
			}
		}, i)
	}

	c.Wait()
}

Inspired by

• eddycjy/gsema - a simple goroutine limit pool.

License

GoZoox is released under the MIT License.

Documentation

Index

• type Cocurrent
  • func New(limit int) *Cocurrent
  • func (c *Cocurrent) Add(task func(args ...interface{}), args ...interface{})
  • func (c *Cocurrent) Done()
  • func (c *Cocurrent) Wait()

Types

type Cocurrent

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

Cocurrent is a concurrent object

func New

func New(limit int) *Cocurrent

New creates a new cocurrent object

func (*Cocurrent) Add

func (c *Cocurrent) Add(task func(args ...interface{}), args ...interface{})

Add adds a new task to the cocurrent object

func (*Cocurrent) Done

func (c *Cocurrent) Done()

Done removes a task from the cocurrent object

func (*Cocurrent) Wait

func (c *Cocurrent) Wait()

Wait waits for all tasks to be done