Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type WorkGroup ¶
type WorkGroup interface {
io.Closer
Engine() string // the engine being used
Add(job *GroupJob) // Adds a job to this group
Wait() error // Waits for this group to finish, returning any errors
UWait(err error) error // Same as wait, but only returns an error iff the given one is not nil
}
WorkGroup represents a group that performs parallel work
func NewWorkGroup ¶
NewWorkGroup creates a new work group xthreads is the maximal number of parallel jobs <= 0 for unlimited. needsSync should be true if jobs also need to perform syncronous work, such as logging
Source Files
Click to show internal directories.
Click to hide internal directories.