Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Accelerator ¶
type Accelerator struct {
// contains filtered or unexported fields
}
Accelerator putting your events and handling process into this accelerator to execute them in concurrency
func NewAccelerator ¶
func NewAccelerator(size int, done <-chan struct{}) *Accelerator
NewAccelerator initializing a new accelerator
func (*Accelerator) Accelerate ¶
func (ac *Accelerator) Accelerate(fn func(), hashKey string)
Accelerate The purpose of this accelerator is twofold: 1.dividing the events into a group of channels by calculating hash code of event's name 2.there is one goroutine for each channel is waiting for handling the accelerate request
type ExeRequest ¶
type ExeRequest struct {
// contains filtered or unexported fields
}
ExeRequest ...
Source Files
Click to show internal directories.
Click to hide internal directories.