combiner

Documentation

Index

• Variables
• type Batcher
• type Flat
  • func (q *Flat) Do(request func())
• type Remote
  • func NewRemote(bat Batcher) *Remote
  • func (c *Remote) Close()
  • func (c *Remote) Do(arg interface{})
  • func (c *Remote) Run()
• type TBB
  • func NewTBB(batcher Batcher) *TBB
  • func (c *TBB) Do(op interface{})
  • func (c *TBB) DoAsync(op interface{})
• type TBBSleepy
  • func NewTBBSleepy(batcher Batcher) *TBBSleepy
  • func (c *TBBSleepy) Do(op interface{})
  • func (c *TBBSleepy) DoAsync(op interface{})
• type TBBSleepyUintptr
  • func NewTBBSleepyUintptr(batcher Batcher) *TBBSleepyUintptr
  • func (c *TBBSleepyUintptr) Do(arg interface{})
• type TBBUintptr
  • func NewTBBUintptr(batcher Batcher) *TBBUintptr
  • func (c *TBBUintptr) Do(arg interface{})

Variables

var All = testsuite.Descs{
	{"TBB", false, func(bat testsuite.Batcher, bound int) testsuite.Combiner { return NewTBB(bat) }},
	{"TBBS", false, func(bat testsuite.Batcher, bound int) testsuite.Combiner { return NewTBBSleepy(bat) }},
	{"TBBU", false, func(bat testsuite.Batcher, bound int) testsuite.Combiner { return NewTBBUintptr(bat) }},
	{"TBBSU", false, func(bat testsuite.Batcher, bound int) testsuite.Combiner { return NewTBBSleepyUintptr(bat) }},
	{"Remote", false, func(bat testsuite.Batcher, bound int) testsuite.Combiner { return NewRemote(bat) }},
}

Types

type Batcher

type Batcher interface {
	Start()
	Include(op interface{})
	Finish()
}

type Flat

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

func (*Flat) Do

func (q *Flat) Do(request func())

type Remote

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

func NewRemote

func NewRemote(bat Batcher) *Remote

func (*Remote) Close

func (c *Remote) Close()

func (*Remote) Do

func (c *Remote) Do(arg interface{})

func (*Remote) Run

func (c *Remote) Run()

type TBB

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

based on https://software.intel.com/en-us/blogs/2013/02/22/combineraggregator-synchronization-primitive

func NewTBB

func NewTBB(batcher Batcher) *TBB

func (*TBB) Do

func (c *TBB) Do(op interface{})

func (*TBB) DoAsync

func (c *TBB) DoAsync(op interface{})

type TBBSleepy

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

based on https://software.intel.com/en-us/blogs/2013/02/22/combineraggregator-synchronization-primitive

func NewTBBSleepy

func NewTBBSleepy(batcher Batcher) *TBBSleepy

func (*TBBSleepy) Do

func (c *TBBSleepy) Do(op interface{})

func (*TBBSleepy) DoAsync

func (c *TBBSleepy) DoAsync(op interface{})

type TBBSleepyUintptr

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

based on https://software.intel.com/en-us/blogs/2013/02/22/combineraggregator-synchronization-primitive

func NewTBBSleepyUintptr

func NewTBBSleepyUintptr(batcher Batcher) *TBBSleepyUintptr

func (*TBBSleepyUintptr) Do

func (c *TBBSleepyUintptr) Do(arg interface{})

type TBBUintptr

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

based on https://software.intel.com/en-us/blogs/2013/02/22/combineraggregator-synchronization-primitive

func NewTBBUintptr

func NewTBBUintptr(batcher Batcher) *TBBUintptr

func (*TBBUintptr) Do

func (c *TBBUintptr) Do(arg interface{})