Run scalaz задачи на пользовательском пуле (ExecutorService)

Question

У меня есть обслуживание на заказ Исполнитель:

val executorService = Executors.newSingleThreadExecutor() 

И у меня есть задачи:

val tasks = Task(1).flatMap { i => 
    Task(i + 1) 
} 

Я знаю, что я могу передать executorService для каждой задачи:

val tasks = Task(1)(executorService).flatMap { i => 
    Task(i + 1)(executorService) 
} 

Но что делать, если эти задачи возвращены из какой-либо библиотеки и не созданы моим кодом.

Как я могу запустить tasks используя executorService?

Answer 1

Это может быть сделано с помощью Task.fork:

Возвращает Task, который производит тот же результат, что и данной Future, но вилок его оценка в отдельный (логический) поток, используя данный ExecutorService.

val alienTask = Task.delay(5) 
val myExecutorService = Executors.newSingleThreadExecutor() 
val myTask = Task.fork(alienTask)(myExecutorService)