I futures sono eseguiti su un singolo thread? (Scala)

Question

Utilizzando il contesto di esecuzione implicito predefinito in Scala, ciascun nuovo futuro verrà calcolato su un singolo thread dedicato o il calcolo verrà diviso e distribuito a più thread nel pool di thread?

Non so se questo aiuti, lo sfondo di questa domanda è che voglio eseguire più operazioni simultanee utilizzando l'API HtmlUnit. Per fare questo, vorrei avvolgere ogni nuova istanza WebClient in un futuro. L'unico problema è che la classe WebClient non è thread-safe, quindi sono preoccupato che potrebbe essere suddiviso e inviato a thread diversi.

Answer 1

Un futuro viene eseguito su un singolo thread. Diversi futuri potrebbero essere eseguiti su più thread. Quindi, non più che in futuro, possiamo occupare un thread simultaneamente.

Come funziona? Quando crei un Futuro significa che hai inviato l'attività al tuo pool di thread: questa attività non può essere parallelamente implicita in modo che venga eseguita su un solo thread. Una o più attività inviate al pool vengono inserite nella coda del pool, quindi l'esecutore prende le attività da quella coda una alla volta ed esegue ciascuna su un thread scelto casualmente (o intenzionalmente). Quindi molti Futures possono arrivare a diversi thread.

Informazioni sull'oggetto condiviso: l'unico modo per eseguire le operazioni in modo sicuro per l'oggetto condiviso tra i futures è utilizzando Executors.newFixedThreadPool(1), verrà utilizzato un solo thread per l'intero pool. Un'altra soluzione - è quella di clonare tale oggetto per ogni futuro. Usare gli attori (rendere il tuo oggetto condiviso lo stato di un attore) dovrebbe essere l'opzione migliore.

Se si utilizza un oggetto per il futuro, tutto dovrebbe andare bene.

Nota: il gestore del futuro, come Future{ ... }.map(handler), può essere eseguito in thread diversi rispetto al futuro stesso, ma in realtà crea un altro Future per ottenere un risultato. Lo stesso per flatMap. Più precisamente, usano onComplete che crea CallbackRunnable lanciare handler (possibile in thread differente), dopo il successo storico di futuro - questo callback appena completato futuro newely creato, quindi ancora "non più di un thread per il futuro"

Answer 2

Un Future[+T] non può garantire che sarà completato sullo stesso thread se è composto da più futures. Detto questo, ciò non significa che otterrai un'eccezione di modifica simultanea o qualcosa del genere. È ancora possibile eseguire il codice asincrono in sequenza, nel qual caso sarebbe sicuro.

Per quanto riguarda la seconda domanda, finché si dispone di un'istanza per ogni futuro non si dovrebbero avere problemi di concorrenza.