LocalConcurrentContext (gratum 1.1.15 API)

Summary:
Property
Constructor
Method

| Detail:
Property
Constructor
Method

gratum.concurrency.LocalConcurrentContext

All Implemented Interfaces and Traits:: ConcurrentContext

class LocalConcurrentContext
extends java.lang.Object

Properties Summary

Properties
Type	Name and description
`java.util.concurrent.ArrayBlockingQueue<java.util.Map<java.lang.String, java.lang.Object>>`	`eventQueue`
`java.util.concurrent.CountDownLatch`	`latch`
`PipelineWorker`	`resultProcessor`
`groovy.lang.Closure<Pipeline>`	`resultProcessorClosure`
`java.util.concurrent.ArrayBlockingQueue<java.util.Map<java.lang.String, java.lang.Object>>`	`resultQueue`
`groovy.lang.Closure<Pipeline>`	`workerClosure`
`int`	`workerSize`
`java.util.List<PipelineWorker>`	`workers`

Constructor Summary

Constructors
Constructor and description
`LocalConcurrentContext (int workers = 8, int queueSize = 200)`

Methods Summary

Methods
Type Params	Return Type	Name and description
	`LocalConcurrentContext`	`collect(groovy.lang.Closure<Pipeline> resultsClosure)`
	`groovy.lang.Closure<Pipeline>`	`connect()`
	`void`	`createResultProcessor()`
	`LocalConcurrentContext`	`spread(groovy.lang.Closure<Pipeline> workerClosure)`

Inherited Methods Summary

Inherited Methods
Methods inherited from class	Name
`class java.lang.Object`	`java.lang.Object#wait(long, int), java.lang.Object#wait(long), java.lang.Object#wait(), java.lang.Object#equals(java.lang.Object), java.lang.Object#toString(), java.lang.Object#hashCode(), java.lang.Object#getClass(), java.lang.Object#notify(), java.lang.Object#notifyAll()`

- Property Detail
  - final java.util.concurrent.ArrayBlockingQueue<java.util.Map<java.lang.String, java.lang.Object>> eventQueue
  - final java.util.concurrent.CountDownLatch latch
  - PipelineWorker resultProcessor
  - groovy.lang.Closure<Pipeline> resultProcessorClosure
  - final java.util.concurrent.ArrayBlockingQueue<java.util.Map<java.lang.String, java.lang.Object>> resultQueue
  - groovy.lang.Closure<Pipeline> workerClosure
  - final int workerSize
  - java.util.List<PipelineWorker> workers
- Constructor Detail
  - LocalConcurrentContext(int workers = 8, int queueSize = 200)
- Method Detail
  - LocalConcurrentContext collect(@groovy.lang.DelegatesTo(LocalConcurrentContext) @groovy.transform.stc.ClosureParams(value = FromString, options = ["gratum.etl.Pipeline"]) groovy.lang.Closure<Pipeline> resultsClosure)
  - groovy.lang.Closure<Pipeline> connect()
  - void createResultProcessor()
  - LocalConcurrentContext spread(@groovy.lang.DelegatesTo(LocalConcurrentContext) @groovy.transform.stc.ClosureParams(value = FromString, options = ["gratum.etl.Pipeline"]) groovy.lang.Closure<Pipeline> workerClosure)

Summary:
Property
Constructor
Method

| Detail:
Property
Constructor
Method

Groovy Documentation