module ExecutorCompletionService:sig..end
type t
val make : ThreadPoolExecutor.t -> tval poll : t -> 'a Future.t optionNone.val poll_time : t -> int64 -> TimeUnit.t -> 'a Future.t optionpoll_time s t u is similar to pool s, except that the current
thread will at most wait for t (time value whose unit is u).
Raises Runtime.Interrupted if the thread is interrupted.
val submit : t -> ('a -> 'b) -> 'a -> 'b Future.tThreadPoolExecutor.submit.val take : t -> 'a Future.t
Raises Runtime.Interrupted if the thread is interrupted.