diff --git a/akka.iml b/akka.iml index 3e135f5603..f9d299bab7 100644 --- a/akka.iml +++ b/akka.iml @@ -1,5 +1,10 @@ + + + + + diff --git a/akka.ipr b/akka.ipr index d4cf40a6d0..c324192289 100644 --- a/akka.ipr +++ b/akka.ipr @@ -148,42 +148,15 @@ + + + + + - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - @@ -191,49 +164,6 @@ - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - @@ -421,6 +351,7 @@ + diff --git a/akka.iws b/akka.iws index 59230ef6b6..d20a6273d0 100644 --- a/akka.iws +++ b/akka.iws @@ -2,44 +2,13 @@ - - + - - - - + - - - - - - - - - - - - - - - - - - - - - - - - - - - - - + + @@ -118,25 +87,34 @@ - + - - + + - + - - + + - + + + + + + + + + + @@ -187,118 +165,6 @@ @@ -544,19 +306,19 @@ - + - + - - + + @@ -567,13 +329,13 @@ - - + + - + @@ -582,7 +344,7 @@ - + @@ -718,7 +480,7 @@ - + - + - + - + - + @@ -924,16 +686,16 @@ - + - + - + @@ -986,13 +748,6 @@ - - - - - - - @@ -1021,13 +776,6 @@ - - - - - - - @@ -1042,13 +790,6 @@ - - - - - - - @@ -1056,13 +797,6 @@ - - - - - - - @@ -1070,13 +804,6 @@ - - - - - - - @@ -1084,16 +811,44 @@ - + - + - + - + + + + + + + + + + + + + + + + + + + + + + + + + + + + + diff --git a/api-java/akka-funtest-java.iml b/api-java/akka-funtest-java.iml deleted file mode 100644 index 62e899a6d4..0000000000 --- a/api-java/akka-funtest-java.iml +++ /dev/null @@ -1,87 +0,0 @@ - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - diff --git a/fun-test-java/api-java.iml b/fun-test-java/api-java.iml deleted file mode 100755 index a1843c1554..0000000000 --- a/fun-test-java/api-java.iml +++ /dev/null @@ -1,99 +0,0 @@ - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - diff --git a/kernel/src/main/scala/reactor/EventDrivenDispatcher.scala b/kernel/src/main/scala/reactor/EventDrivenDispatcher.scala index 3ba3c2ea50..000d795a74 100644 --- a/kernel/src/main/scala/reactor/EventDrivenDispatcher.scala +++ b/kernel/src/main/scala/reactor/EventDrivenDispatcher.scala @@ -17,6 +17,7 @@ class EventDrivenDispatcher extends MessageDispatcher { private val handlers = new ConcurrentHashMap[AnyRef, MessageHandler] private var selectorThread: Thread = _ @volatile private var active: Boolean = false + private val guard = new Object def registerHandler(key: AnyRef, handler: MessageHandler) = handlers.put(key, handler) @@ -28,6 +29,7 @@ class EventDrivenDispatcher extends MessageDispatcher { selectorThread = new Thread { override def run = { while (active) { + guard.synchronized { /* empty */ } messageDemultiplexer.select val handles = messageDemultiplexer.acquireSelectedQueue val handlesList = handles.toArray.toList.asInstanceOf[List[MessageHandle]] diff --git a/kernel/src/main/scala/reactor/Reactor.scala b/kernel/src/main/scala/reactor/Reactor.scala index c3cf6899a2..399404e85d 100644 --- a/kernel/src/main/scala/reactor/Reactor.scala +++ b/kernel/src/main/scala/reactor/Reactor.scala @@ -12,8 +12,6 @@ package se.scalablesolutions.akka.kernel.reactor import java.util.{LinkedList, Queue} -import kernel.reactor.CompletableFutureResult - trait MessageDispatcher { def registerHandler(key: AnyRef, handler: MessageHandler) def unregisterHandler(key: AnyRef)