concurrency

README

• Run tests with go test .
• Run benchmarks with go test -bench=. or specific benchmark with go test -test.bench=SumConcurrency

Documentation

Index

• func Add(data []int, split int) int
• func SumIt(n int, concurrency int) int
• type Counter
  • func NewCounter(close <-chan bool) *Counter
  • func (c *Counter) Close()
  • func (c *Counter) Get(key string) int
  • func (c *Counter) Incr(key string)
  • func (c *Counter) Report()
• type Metric
  • func NewMetrics() *Metric
  • func (m *Metric) Get(key string) int
  • func (m *Metric) Incr(key string)
  • func (m *Metric) Report()

Functions

func Add

func Add(data []int, split int) int

func SumIt

func SumIt(n int, concurrency int) int

Types

type Counter

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

func NewCounter

func NewCounter(close <-chan bool) *Counter

func (*Counter) Close

func (c *Counter) Close()

func (*Counter) Get

func (c *Counter) Get(key string) int

func (*Counter) Incr

func (c *Counter) Incr(key string)

func (*Counter) Report

func (c *Counter) Report()

type Metric

type Metric struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewMetrics

func NewMetrics() *Metric

func (*Metric) Get

func (m *Metric) Get(key string) int

func (*Metric) Incr

func (m *Metric) Incr(key string)

func (*Metric) Report

func (m *Metric) Report()