Example of using custom executor with Akka 1.0

gistfile1.txt

import java.util.concurrent.ExecutorService
import java.util.concurrent.atomic.AtomicReference

import akka.dispatch.ExecutorBasedEventDrivenDispatcher
import akka.dispatch.Dispatchers
import akka.dispatch.MailboxType

abstract class ExecutorDispatcher(
 name: String,
 throughput: Int = Dispatchers.THROUGHPUT,
 throughputDeadlingTime: Int = Dispatchers.THROUGHPUT_DEADLINE_TIME_MILLIS,
 mailboxType: MailboxType = Dispatchers.MAILBOX_TYPE)
 extends ExecutorBasedEventDrivenDispatcher(name, throughput, throughputDeadlingTime, mailboxType) {

 override val executorService = new AtomicReference[ExecutorService](createExecutor)
 
 override def shutdown {
   val old = executorService.getAndSet(createExecutor)
   if (old != null) {
     old.shutdownNow
   }
 }
 
 protected def createExecutor: ExecutorService
}