Run scalaz Aufgaben auf individuellen Pool (ExecutorService)

Question

ich einen benutzerdefinierten Testamentsvollstrecker Service habe:

val executorService = Executors.newSingleThreadExecutor() 

Und ich habe Aufgaben:

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

Ich weiß, dass ich executorService jede Aufgabe passieren kann:

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

Aber was ist, wenn diese Aufgaben von einer Bibliothek zurückgegeben werden und nicht von meinem Code erstellt werden. Wie kann ich tasks mit executorService ausführen?

Answer 1

Dies kann unter Verwendung von Task.fork:

eine Task zurück, der das gleiche Ergebnis wie die gegebene Future erzeugt, aber ihre Bewertung Gabeln ab in einem separaten (logischen) Gewinde, die gegebene ExecutorService verwenden.

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