public class PoolFiberFactory extends Object implements Disposable
Fiber
instances that share threads.Constructor and Description |
---|
PoolFiberFactory(Executor exec) |
PoolFiberFactory(Executor executor,
ScheduledExecutorService sched)
Construct a new instance.
|
Modifier and Type | Method and Description |
---|---|
Fiber |
create()
Create a new Fiber from this pool.
|
Fiber |
create(BatchExecutor batchExecutor)
Create a new Fiber from this pool that uses the supplied
Executor to execute commands |
void |
dispose()
Dispose this instance.
|
public PoolFiberFactory(Executor executor, ScheduledExecutorService sched)
executor
- Executor to use for flushing pending commands for each created Fiberpublic PoolFiberFactory(Executor exec)
public Fiber create()
create(BatchExecutor)
with a SynchronousExecutor
public Fiber create(BatchExecutor batchExecutor)
Executor
to execute commandsbatchExecutor
- Executor to use for command executor. Required.public void dispose()
Disposable
dispose
in interface Disposable
Copyright © 2017. All Rights Reserved.