 Documentation
      ¶
      Documentation
      ¶
    
    
  
    
  
    Index ¶
Constants ¶
This section is empty.
Variables ¶
      View Source
      
  var ErrPoolClosed = ants.ErrPoolClosed
    ErrPoolClosed is returned when submitting task to a closed pool.
Functions ¶
func MkdirAllX ¶ added in v0.24.0
MkdirAllX calls os.MkdirAll with the passed permissions but with +x for a user and a group. This makes the created dir openable regardless of the passed permissions.
func NewSaltingWriter ¶ added in v0.14.1
NewSaltingWriter returns io.Writer instance that applies salt to written data and write the result to w.
func SaltXOROffset ¶ added in v0.14.1
SaltXOROffset xors bits of data with salt starting from off byte repeating salt if necessary.
Types ¶
type WorkerPool ¶
type WorkerPool interface {
	// Submit queues a function for execution
	// in a separate routine.
	//
	// Implementation must return any error encountered
	// that prevented the function from being queued.
	Submit(func()) error
	// Release releases worker pool resources. All `Submit` calls will
	// finish with ErrPoolClosed. It doesn't wait until all submitted
	// functions have returned so synchronization must be achieved
	// via other means (e.g. sync.WaitGroup).
	Release()
	// Tune changes the capacity of this pool.
	Tune(int)
}
    WorkerPool represents a tool to control the execution of go-routine pool.
func NewPseudoWorkerPool ¶ added in v0.26.1
func NewPseudoWorkerPool() WorkerPool
NewPseudoWorkerPool returns a new instance of a synchronous worker pool.
 Click to show internal directories. 
   Click to hide internal directories.