Jak wyznaczyć pulę wątków dla aktorów

Question

Mam istniejącą aplikację java/scala używającą globalnej puli wątków. Chciałbym rozpocząć korzystanie z aktorów w projekcie, ale chciałbym, aby wszystko w aplikacji korzystało z tej samej puli.

Wiem, że mogę ustawić maksymalną liczbę wątków, których używają aktorzy, ale wolałbym dzielić pulę wątków. Czy jest to konieczne/uzasadnione i czy można wyznaczyć pulę wątków aktora?

Jeśli nie jest to możliwe/zalecane, czy istnieją jakieś praktyczne reguły podczas integrowania aktorów w aplikacjach, które już używają wątków?

Dzięki.

Answer 1

Wierzę, że można zrobić coś takiego:

trait MyActor extends Actor { 
    val pool = ... // git yer thread pool here 
    override def scheduler = new SchedulerAdapter { 
    def execute(block: => Unit) = 
     pool.execute(new Runnable { 
     def run() { block } 
     }) 
    } 
} 

Answer 2

Ale to dość łatwe do ponownego korzystania z basenu nici użytej przez podsystem aktora. Po pierwsze można kontrolować jej rozmiar:

-Dactors.maxPoolSize=8 

I można powoływać się na nią prace:

actors.Scheduler.execute(f); //f is => Unit 

Jedyne co brakuje jest zdolność do planowania pracy. Do tego używam oddzielnego ScheduledExecutorService który jest jednowątkowy i prowadzi prace nad basenem aktorzy wątku:

object MyScheduler { 
    private val scheduler = Executors.newSingleThreadedScheduledExecutorService 

    def schedule(f: => Unit, delay: (Long, TimeUnit)) : ScheduledFuture[_] = { 
     scheduler.schedule(new ScheduledRun(f), delay._1, delay._2) 
    } 

    private class ScheduledRun(f: => Unit) extends Runnable { 
    def run = actors.Scheduler.execute(f) 
    } 

} 

Następnie można użyć tego, aby zaplanować coś:

MyScheduler.schedule(f, (60, SECONDS)) 

Answer 3

dla Scala 2.8 .1 to:

scala -Dactors.corePoolSize=20