MultiThreadedActors extends Actors { @Override void startActorThread(MessageProcessor actorThread) { executor.execute(new BlockingActorProcessor(actorThread)); } MultiThreadedActors(Executor executor, EventizerProvider eventizerProvider, FailureHandler failureHandler, MessageListener messageListener);   }
@Test public void actor_threads_are_backed_by_real_threads() throws InterruptedException { SpyDummyListener rawActor = new SpyDummyListener(); ActorThread actorThread = actors.startActorThread(); ActorRef<DummyListener> actorRef = actorThread.bindActor(DummyListener.class, rawActor); actorRef.tell().onSomething("event"); awaitEvents(1); assertThat(rawActor.thread, is(notNullValue())); assertThat(rawActor.thread, is(not(Thread.currentThread()))); }