private final
class
BasicAsyncHelper
extends
BaseAsyncHelper
Constructors
BasicAsyncHelper
(
phase:
Phase
)
BasicAsyncHelper
(
implicit
ctx:
Context
)
Members
override
def
newBoundedQueueFixedThreadPool
(
nThreads:
Int
,
maxQueueSize:
Int
,
rejectHandler:
RejectedExecutionHandler
,
shortId:
String
,
priority:
Int
)
: ThreadPoolExecutor
override
def
newUnboundedQueueFixedThreadPool
(
nThreads:
Int
,
shortId:
String
,
priority:
Int
)
: ThreadPoolExecutor
protected override
def
wrapRunnable
(
r:
Runnable
,
shortId:
String
)
: Runnable