coroutine

README

Coroutine

Usage

package main

import (
	"log"

	"github.com/go-kratos-ecosystem/components/v2/coroutine"
)

func main() {
	funcs := []func(){
		func() {
			log.Println("1")
		},
		func() {
			log.Println("2")
		},
		func() {
			log.Println("3")
		},
	}

	// Concurrent Example1
	c := coroutine.NewConcurrent(2)
	defer c.Close()
	c.Add(funcs...)

	c.Wait()

	// Concurrent Example2
	coroutine.RunConcurrent(2, funcs...)

	// Parallel Example1
	p := coroutine.NewParallel()
	p.Add(funcs...)
	p.Wait()

	// Parallel Example2
	coroutine.RunParallel(funcs...)
}

Documentation

Index

• func RunConcurrent(limit int, tasks ...func())
• func RunParallel(fs ...func())
• type Concurrent
  • func NewConcurrent(limit int) *Concurrent
  • func (c *Concurrent) Add(fs ...func()) *Concurrent
  • func (c *Concurrent) Close()
  • func (c *Concurrent) Wait()
• type Parallel
  • func NewParallel() *Parallel
  • func (p *Parallel) Add(fs ...func()) *Parallel
  • func (p *Parallel) Wait()

Functions

func RunConcurrent

func RunConcurrent(limit int, tasks ...func())

func RunParallel

func RunParallel(fs ...func())

Types

type Concurrent

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

func NewConcurrent

func NewConcurrent(limit int) *Concurrent

func (*Concurrent) Add

func (c *Concurrent) Add(fs ...func()) *Concurrent

func (*Concurrent) Close

func (c *Concurrent) Close()

func (*Concurrent) Wait

func (c *Concurrent) Wait()

type Parallel

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

func NewParallel

func NewParallel() *Parallel

func (*Parallel) Add

func (p *Parallel) Add(fs ...func()) *Parallel

func (*Parallel) Wait

func (p *Parallel) Wait()