raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11

Removing dead imports from akka-actor

Browse source
This commit is contained in:
Viktor Klang 2012-01-25 15:38:04 +01:00
parent 7f3a9cd756
commit f7a45c0e8f
27 changed files with 20 additions and 75 deletions
Download patch file Download diff file Expand all files Collapse all files

1
akka-actor/src/main/java/akka/dispatch/AbstractMessageDispatcher.java
View file

@ -6,7 +6,6 @@ package akka.dispatch;
import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;
import java.util.concurrent.atomic.AtomicLongFieldUpdater;
import java.util.concurrent.atomic.AtomicReferenceFieldUpdater;
abstract class AbstractMessageDispatcher {
private volatile int _shutdownSchedule; // not initialized because this is faster: 0 == UNSCHEDULED

11
akka-actor/src/main/scala/akka/actor/Actor.scala
View file

@ -4,20 +4,9 @@
package akka.actor
import akka.dispatch._
import akka.routing._
import akka.util.Duration
import akka.japi.{ Creator, Procedure }
import akka.serialization.{ Serializer, Serialization }
import akka.event.Logging.Debug
import akka.event.LogSource
import akka.experimental
import akka.AkkaException
import scala.reflect.BeanProperty
import scala.util.control.NoStackTrace
import com.eaio.uuid.UUID
import java.util.concurrent.TimeUnit
import java.util.{ Collection ⇒ JCollection }
import java.util.regex.Pattern
/**

5
akka-actor/src/main/scala/akka/actor/ActorRef.scala
View file

@ -9,13 +9,10 @@ import akka.util._
import scala.collection.immutable.Stack
import java.lang.{ UnsupportedOperationException, IllegalStateException }
import akka.serialization.Serialization
import java.util.concurrent.TimeUnit
import akka.event.EventStream
import akka.event.DeathWatch
import scala.annotation.tailrec
import java.util.concurrent.{ ConcurrentHashMap, TimeoutException }
import java.util.concurrent.{ ConcurrentHashMap }
import akka.event.LoggingAdapter
import java.util.concurrent.atomic.AtomicBoolean
/**
* Immutable and serializable handle to an actor, which may or may not reside

3
akka-actor/src/main/scala/akka/actor/ActorRefProvider.scala
View file

@ -5,11 +5,10 @@
package akka.actor
import java.util.concurrent.atomic.AtomicLong
import akka.config.ConfigurationException
import akka.dispatch._
import akka.routing._
import akka.AkkaException
import akka.util.{ Duration, Switch, Helpers, Timeout }
import akka.util.{ Switch, Helpers }
import akka.event._
/**

2
akka-actor/src/main/scala/akka/actor/ActorSystem.scala
View file

@ -7,8 +7,6 @@ import akka.config.ConfigurationException
import akka.event._
import akka.dispatch._
import akka.pattern.ask
import akka.util.duration._
import akka.util.Timeout._
import org.jboss.netty.akka.util.HashedWheelTimer
import java.util.concurrent.TimeUnit.MILLISECONDS
import com.typesafe.config.Config

5
akka-actor/src/main/scala/akka/actor/Deployer.scala
View file

@ -4,12 +4,7 @@
package akka.actor
import collection.immutable.Seq
import akka.event.Logging
import akka.AkkaException
import akka.config.ConfigurationException
import akka.util.Duration
import akka.event.EventStream
import com.typesafe.config._
import akka.routing._
import java.util.concurrent.{ TimeUnit, ConcurrentHashMap }

1
akka-actor/src/main/scala/akka/actor/FSM.scala
View file

@ -7,7 +7,6 @@ import akka.util._
import scala.collection.mutable
import akka.event.Logging
import akka.util.Duration._
import akka.routing.{ Deafen, Listen, Listeners }
object FSM {

1
akka-actor/src/main/scala/akka/actor/FaultHandling.scala
View file

@ -4,7 +4,6 @@
package akka.actor
import java.util.concurrent.TimeUnit
import scala.annotation.tailrec
import scala.collection.mutable.ArrayBuffer
import scala.collection.JavaConversions._
import java.lang.{ Iterable ⇒ JIterable }

1
akka-actor/src/main/scala/akka/actor/Locker.scala
View file

@ -5,7 +5,6 @@ package akka.actor
import akka.dispatch._
import akka.util.Duration
import akka.util.duration._
import java.util.concurrent.ConcurrentHashMap
import akka.event.DeathWatch

1
akka-actor/src/main/scala/akka/actor/Props.scala
View file

@ -6,7 +6,6 @@ package akka.actor
import akka.dispatch._
import akka.japi.Creator
import akka.util._
import collection.immutable.Stack
import akka.routing._

2
akka-actor/src/main/scala/akka/actor/Scheduler.scala
View file

@ -13,7 +13,7 @@
package akka.actor
import akka.util.Duration
import org.jboss.netty.akka.util.{ Timer, TimerTask, HashedWheelTimer, Timeout ⇒ HWTimeout }
import org.jboss.netty.akka.util.{ TimerTask, HashedWheelTimer, Timeout ⇒ HWTimeout }
import akka.event.LoggingAdapter
import akka.dispatch.MessageDispatcher
import java.io.Closeable

4
akka-actor/src/main/scala/akka/actor/TypedActor.scala
View file

@ -6,9 +6,9 @@ package akka.actor
import akka.japi.{ Creator, Option ⇒ JOption }
import java.lang.reflect.{ InvocationTargetException, Method, InvocationHandler, Proxy }
import akka.util.{ Duration, Timeout }
import akka.util.{ Timeout }
import java.util.concurrent.atomic.{ AtomicReference ⇒ AtomVar }
import akka.serialization.{ Serializer, Serialization, SerializationExtension }
import akka.serialization.{ Serialization, SerializationExtension }
import akka.dispatch._
import java.util.concurrent.TimeoutException
import java.lang.IllegalStateException

3
akka-actor/src/main/scala/akka/actor/UntypedActor.scala
View file

@ -4,8 +4,7 @@
package akka.actor
import akka.japi.{ Creator, Procedure }
import akka.dispatch.{ MessageDispatcher, Promise }
import akka.japi.{ Creator }
/**
* Actor base trait that should be extended by or mixed to create an Actor with the semantics of the 'Actor Model':

6
akka-actor/src/main/scala/akka/dispatch/BalancingDispatcher.scala
View file

@ -5,13 +5,9 @@
package akka.dispatch
import util.DynamicVariable
import akka.actor.{ ActorCell, Actor, IllegalActorStateException, ActorRef }
import akka.actor.{ ActorCell, ActorRef }
import java.util.concurrent.{ LinkedBlockingQueue, ConcurrentLinkedQueue, ConcurrentSkipListSet }
import java.util.{ Comparator, Queue }
import annotation.tailrec
import akka.actor.ActorSystem
import akka.event.EventStream
import akka.actor.Scheduler
import java.util.concurrent.atomic.AtomicBoolean
import akka.util.Duration

3
akka-actor/src/main/scala/akka/dispatch/Dispatchers.scala
View file

@ -9,12 +9,9 @@ import akka.util.{ Duration, ReflectiveAccess }
import akka.actor.ActorSystem
import akka.event.EventStream
import akka.actor.Scheduler
import akka.actor.ActorSystem.Settings
import com.typesafe.config.Config
import com.typesafe.config.ConfigFactory
import akka.config.ConfigurationException
import akka.event.Logging.Warning
import akka.actor.Props
import java.util.concurrent.{ ThreadFactory, TimeUnit, ConcurrentHashMap }
trait DispatcherPrerequisites {

11
akka-actor/src/main/scala/akka/dispatch/Future.scala
View file

@ -4,25 +4,22 @@
package akka.dispatch
import akka.AkkaException
import akka.event.Logging.Error
import akka.util.Timeout
import scala.Option
import akka.japi.{ Procedure, Function ⇒ JFunc, Option ⇒ JOption }
import akka.japi.{ Function ⇒ JFunc, Option ⇒ JOption }
import scala.util.continuations._
import java.util.concurrent.TimeUnit.{ NANOSECONDS, MILLISECONDS }
import java.util.concurrent.TimeUnit.{ NANOSECONDS }
import java.lang.{ Iterable ⇒ JIterable }
import java.util.{ LinkedList ⇒ JLinkedList }
import scala.annotation.tailrec
import scala.collection.mutable.Stack
import akka.util.{ Switch, Duration, BoxedType }
import java.util.concurrent.atomic.{ AtomicReferenceFieldUpdater, AtomicInteger, AtomicBoolean }
import akka.util.{ Duration, BoxedType }
import java.util.concurrent.atomic.{ AtomicReferenceFieldUpdater, AtomicInteger }
import akka.dispatch.Await.CanAwait
import java.util.concurrent._
import akka.actor.ActorSystem
object Await {
sealed trait CanAwait

1
akka-actor/src/main/scala/akka/dispatch/Mailbox.scala
View file

@ -10,7 +10,6 @@ import akka.actor.{ ActorCell, ActorRef }
import java.util.concurrent._
import annotation.tailrec
import akka.event.Logging.Error
import com.typesafe.config.Config
import akka.actor.ActorContext
class MessageQueueAppendFailedException(message: String, cause: Throwable = null) extends AkkaException(message, cause)

5
akka-actor/src/main/scala/akka/dispatch/PinnedDispatcher.scala
View file

@ -4,13 +4,8 @@
package akka.dispatch
import java.util.concurrent.atomic.AtomicReference
import akka.actor.ActorCell
import akka.actor.ActorSystem
import akka.event.EventStream
import akka.actor.Scheduler
import akka.util.Duration
import java.util.concurrent.TimeUnit
/**
* Dedicates a unique thread for each actor passed in as reference. Served through its messageQueue.

2
akka-actor/src/main/scala/akka/dispatch/PromiseStream.scala
View file

@ -6,7 +6,7 @@ package akka.dispatch
import java.util.concurrent.atomic.AtomicReference
import scala.util.continuations._
import scala.annotation.{ tailrec }
import scala.annotation.tailrec
import akka.util.Timeout
object PromiseStream {

2
akka-actor/src/main/scala/akka/dispatch/ThreadPoolBuilder.scala
View file

@ -5,7 +5,7 @@
package akka.dispatch
import java.util.Collection
import java.util.concurrent.atomic.{ AtomicLong, AtomicInteger }
import java.util.concurrent.atomic.AtomicLong
import akka.util.Duration
import java.util.concurrent._

3
akka-actor/src/main/scala/akka/dispatch/japi/Future.scala
View file

@ -3,8 +3,7 @@
*/
package akka.dispatch.japi
import akka.util.Timeout
import akka.japi.{ Procedure2, Procedure, Function ⇒ JFunc, Option ⇒ JOption }
import akka.japi.{ Procedure2, Procedure, Function ⇒ JFunc }
/* Java API */
trait Future[+T] { self: akka.dispatch.Future[T] ⇒

5
akka-actor/src/main/scala/akka/routing/ConnectionManager.scala
View file

@ -6,11 +6,6 @@ package akka.routing
import akka.actor._
import scala.annotation.tailrec
import java.util.concurrent.atomic.{ AtomicReference, AtomicInteger }
import collection.JavaConverters
/**
* An Iterable that also contains a version.
*/

6
akka-actor/src/main/scala/akka/routing/Routing.scala
View file

@ -4,11 +4,9 @@
package akka.routing
import akka.actor._
import akka.dispatch.{ Future, Promise }
import java.util.concurrent.atomic.AtomicLong
import java.util.concurrent.atomic.AtomicBoolean
import java.util.concurrent.atomic.{ AtomicLong, AtomicBoolean }
import java.util.concurrent.TimeUnit
import akka.util.{ Duration, Timeout }
import akka.util.Duration
import akka.util.duration._
import com.typesafe.config.Config
import akka.config.ConfigurationException

6
akka-actor/src/main/scala/akka/util/ByteString.scala
View file

@ -3,10 +3,10 @@ package akka.util
import java.nio.ByteBuffer
import java.nio.charset.Charset
import scala.collection.{ IndexedSeqOptimized, LinearSeq }
import scala.collection.mutable.{ Builder, ArrayBuilder, WrappedArray }
import scala.collection.{ IndexedSeqOptimized }
import scala.collection.mutable.{ Builder, WrappedArray }
import scala.collection.immutable.{ IndexedSeq, VectorBuilder }
import scala.collection.generic.{ CanBuildFrom, GenericCompanion }
import scala.collection.generic.{ CanBuildFrom }
object ByteString {

3
akka-actor/src/main/scala/akka/util/Duration.scala
View file

@ -6,8 +6,7 @@ package akka.util
import java.util.concurrent.TimeUnit
import TimeUnit._
import java.lang.{ Long ⇒ JLong, Double ⇒ JDouble }
import akka.actor.ActorSystem
import java.lang.{ Double ⇒ JDouble }
class TimerException(message: String) extends RuntimeException(message)

1
akka-actor/src/main/scala/akka/util/Helpers.scala
View file

@ -3,7 +3,6 @@
*/
package akka.util
import java.io.{ PrintWriter, StringWriter }
import java.util.Comparator
import scala.annotation.tailrec
import java.util.regex.Pattern

1
akka-actor/src/main/scala/akka/util/ReflectiveAccess.scala
View file

@ -4,7 +4,6 @@
package akka.util
import akka.actor._
import java.lang.reflect.InvocationTargetException
object ReflectiveAccess {