Packages

object FuturePool

Note: There is a Java-friendly API for this object: com.twitter.util.FuturePools.

Linear Supertypes
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. FuturePool
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. def apply(executor: ExecutorService): ExecutorServiceFuturePool

    Creates a FuturePool backed by an java.util.concurrent.ExecutorService.

  5. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  6. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )
  7. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  8. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  9. def finalize(): Unit
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  10. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  11. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  12. val immediatePool: FuturePool

    A FuturePool that really isn't; it executes tasks immediately without waiting.

    A FuturePool that really isn't; it executes tasks immediately without waiting. This can be useful in unit tests.

  13. def interruptible(executor: ExecutorService): ExecutorServiceFuturePool

    Creates a FuturePool backed by an java.util.concurrent.ExecutorService which propagates cancellation.

  14. lazy val interruptibleUnboundedPool: FuturePool

    The default future pool, using a cached threadpool, provided by java.util.concurrent.Executors.newCachedThreadPool.

    The default future pool, using a cached threadpool, provided by java.util.concurrent.Executors.newCachedThreadPool. Note that this is intended for IO concurrency; computational parallelism typically requires special treatment. If an interrupt is raised on a returned Future and the work has started, an attempt will be made to interrupt the worker thread.

  15. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  16. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  17. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  18. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  19. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  20. def toString(): String
    Definition Classes
    AnyRef → Any
  21. lazy val unboundedPool: FuturePool

    The default future pool, using a cached threadpool, provided by java.util.concurrent.Executors.newCachedThreadPool.

    The default future pool, using a cached threadpool, provided by java.util.concurrent.Executors.newCachedThreadPool. Note that this is intended for IO concurrency; computational parallelism typically requires special treatment. If an interrupt is raised on a returned Future and the work has started, the worker thread will not be interrupted.

  22. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  23. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  24. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )

Inherited from AnyRef

Inherited from Any

Ungrouped