multithreading

func (*ThreadTracker) NumActiveThreads ¶

func (t *ThreadTracker) NumActiveThreads() uint64

NumActiveThreads fetches the number of active threads managed by this threadTracker

func (*ThreadTracker) Stop ¶

func (t *ThreadTracker) Stop(stopMode StopMode)

Stop prevents this threadTracker from accepting any more threads

func (*ThreadTracker) TriggerGoroutine ¶

func (t *ThreadTracker) TriggerGoroutine(fn func(inputs []interface{}), inputs []interface{}) error

TriggerGoroutine initiates a new goroutine while tracking it typical usage 1:

threadTracker.TriggerGoroutine(func(inputs []interface{}) {
    fmt.Printf("Hello %s\n", "World")
})

typical usage 2:

threadTracker.TriggerGoroutine(func(inputs []interface{}) {
    fmt.Printf("Hello %s\n", inputs[0])
}, "World")

func (*ThreadTracker) TriggerGoroutineWithDefers ¶

func (t *ThreadTracker) TriggerGoroutineWithDefers(deferredFns []func(), fn func(inputs []interface{}), inputs []interface{}) error

TriggerGoroutineWithDefers initiates a new goroutine while tracking it typical usage:

    threadTracker.TriggerGoroutineWithDefers([]func(){
	       func() { fmt.Printf("this should appear third\n") },
	       func() { fmt.Printf("this should appear second\n") },
    }, func(inputs []interface{}) {
        fmt.Printf("Hello %s -- this should appear first\n", "World")
    })

func (*ThreadTracker) Wait ¶

func (t *ThreadTracker) Wait()

Wait blocks until all goroutines finish