molecule.platform

Platform

abstract class Platform extends Executor

Encapsulate access to underlying platform resources, timers, JVM threads, ....

An external admin thread uses the platform to bootstrap components.

Source
Platform.scala
Linear Supertypes
Executor, AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. Hide All
  2. Show all
  1. Platform
  2. Executor
  3. AnyRef
  4. Any
Visibility
  1. Public
  2. All

Instance Constructors

  1. new Platform()

Abstract Value Members

  1. abstract def monitor: ProcessMonitor

    Platform monitor

  2. abstract def name: String

    Platform name

  3. abstract def scheduler: Scheduler

    Platform scheduler

Concrete Value Members

  1. final def !=(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  2. final def !=(arg0: Any): Boolean

    Definition Classes
    Any

  3. final def ##(): Int

    Definition Classes
    AnyRef → Any

  4. final def ==(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  5. final def ==(arg0: Any): Boolean

    Definition Classes
    Any

  6. final def asInstanceOf[T0]: T0

    Definition Classes
    Any

  7. def clone(): AnyRef

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()

  8. final def eq(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  9. def equals(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any

  10. def execute(task: Runnable): Unit

    Execute a (non-blocking) task using a new user-level thread created by this platform.

    Execute a (non-blocking) task using a new user-level thread created by this platform.

    task

    the (non-blocking) task to execute.

    returns

    unit

    Definition Classes
    Platform → Executor

  11. final def expose[A](ochan: OChan[A])(implicit arg0: Message[A]): OChan[A]

    Expose a streaming channel as a local system-level channel by executing its transformations over this platform.

    Expose a streaming channel as a local system-level channel by executing its transformations over this platform.

    returns

    a system-level channel

  12. final def expose[A](ichan: IChan[A])(implicit arg0: Message[A]): IChan[A]

    Expose a streaming channel as a local system-level channel by executing its transformations over this platform.

    Expose a streaming channel as a local system-level channel by executing its transformations over this platform.

    returns

    a system-level channel

  13. def finalize(): Unit

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()

  14. final def getClass(): java.lang.Class[_]

    Definition Classes
    AnyRef → Any

  15. def hashCode(): Int

    Definition Classes
    AnyRef → Any

  16. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any

  17. final def launch[I1, I2, I3, O1, O2, O3, R](f: (IChan[I1], IChan[I2], IChan[I3], OChan[O1], OChan[O2], OChan[O3]) ⇒ Process[R])(implicit arg0: Message[I1], arg1: Message[I2], arg2: Message[I3], arg3: Message[O1], arg4: Message[O2], arg5: Message[O3], arg6: Message[R]): Connections3x3[I1, I2, I3, O1, O2, O3, R]

    Launch a process

    Launch a process

    f

    a function that binds a process to its channels.

    returns

    the connections

  18. final def launch[I1, I2, O1, O2, O3, R](f: (IChan[I1], IChan[I2], OChan[O1], OChan[O2], OChan[O3]) ⇒ Process[R])(implicit arg0: Message[I1], arg1: Message[I2], arg2: Message[O1], arg3: Message[O2], arg4: Message[O3], arg5: Message[R]): Connections2x3[I1, I2, O1, O2, O3, R]

    Launch a process

    Launch a process

    f

    a function that binds a process to its channels.

    returns

    the connections

  19. final def launch[I1, I2, I3, O1, O2, R](f: (IChan[I1], IChan[I2], IChan[I3], OChan[O1], OChan[O2]) ⇒ Process[R])(implicit arg0: Message[I1], arg1: Message[I2], arg2: Message[I3], arg3: Message[O1], arg4: Message[O2], arg5: Message[R]): Connections3x2[I1, I2, I3, O1, O2, R]

    Launch a process

    Launch a process

    f

    a function that binds a process to its channels.

    returns

    the connections

  20. final def launch[I1, O1, O2, O3, R](f: (IChan[I1], OChan[O1], OChan[O2], OChan[O3]) ⇒ Process[R])(implicit arg0: Message[I1], arg1: Message[O1], arg2: Message[O2], arg3: Message[O3], arg4: Message[R]): Connections1x3[I1, O1, O2, O3, R]

    Launch a process

    Launch a process

    f

    a function that binds a process to its channels.

    returns

    the connections

  21. final def launch[I1, I2, I3, O1, R](f: (IChan[I1], IChan[I2], IChan[I3], OChan[O1]) ⇒ Process[R])(implicit arg0: Message[I1], arg1: Message[I2], arg2: Message[I3], arg3: Message[O1], arg4: Message[R]): Connections3x1[I1, I2, I3, O1, R]

    Launch a process

    Launch a process

    f

    a function that binds a process to its channels.

    returns

    the connections

  22. final def launch[O1, O2, O3, R](f: (OChan[O1], OChan[O2], OChan[O3]) ⇒ Process[R])(implicit arg0: Message[O1], arg1: Message[O2], arg2: Message[O3], arg3: Message[R]): Connections0x3[O1, O2, O3, R]

    Launch a process

    Launch a process

    f

    a function that binds a process to its channels.

    returns

    the connections

  23. final def launch[I1, I2, I3, R](f: (IChan[I1], IChan[I2], IChan[I3]) ⇒ Process[R])(implicit arg0: Message[I1], arg1: Message[I2], arg2: Message[I3], arg3: Message[R]): Connections3x0[I1, I2, I3, R]

    Launch a process

    Launch a process

    f

    a function that binds a process to its channels.

    returns

    the connections

  24. final def launch[I1, I2, O1, O2, R](f: (IChan[I1], IChan[I2], OChan[O1], OChan[O2]) ⇒ Process[R])(implicit arg0: Message[I1], arg1: Message[I2], arg2: Message[O1], arg3: Message[O2], arg4: Message[R]): Connections2x2[I1, I2, O1, O2, R]

    Launch a process

    Launch a process

    f

    a function that binds a process to its channels.

    returns

    the connections

  25. final def launch[I1, O1, O2, R](f: (IChan[I1], OChan[O1], OChan[O2]) ⇒ Process[R])(implicit arg0: Message[I1], arg1: Message[O1], arg2: Message[O2], arg3: Message[R]): Connections1x2[I1, O1, O2, R]

    Launch a process

    Launch a process

    f

    a function that binds a process to its channels.

    returns

    the connections

  26. final def launch[I1, I2, O1, R](f: (IChan[I1], IChan[I2], OChan[O1]) ⇒ Process[R])(implicit arg0: Message[I1], arg1: Message[I2], arg2: Message[O1], arg3: Message[R]): Connections2x1[I1, I2, O1, R]

    Launch a process

    Launch a process

    f

    a function that binds a process to its channels.

    returns

    the connections

  27. final def launch[O1, O2, R](f: (OChan[O1], OChan[O2]) ⇒ Process[R])(implicit arg0: Message[O1], arg1: Message[O2], arg2: Message[R]): Connections0x2[O1, O2, R]

    Launch a process

    Launch a process

    f

    a function that binds a process to its channels.

    returns

    the connections

  28. final def launch[I1, I2, R](f: (IChan[I1], IChan[I2]) ⇒ Process[R])(implicit arg0: Message[I1], arg1: Message[I2], arg2: Message[R]): Connections2x0[I1, I2, R]

    Launch a process

    Launch a process

    f

    a function that binds a process to its channels.

    returns

    the connections

  29. final def launch[I1, O1, R](f: (IChan[I1], OChan[O1]) ⇒ Process[R])(implicit arg0: Message[I1], arg1: Message[O1], arg2: Message[R]): Connections1x1[I1, O1, R]

    Launch a process

    Launch a process

    f

    a function that binds a process to its channels.

    returns

    the connections

  30. final def launch[O1, R](f: (OChan[O1]) ⇒ Process[R])(implicit arg0: Message[O1], arg1: Message[R]): Connections0x1[O1, R]

    Launch a process

    Launch a process

    f

    a function that binds a process to its channels.

    returns

    the connections

  31. final def launch[I1, R](f: (IChan[I1]) ⇒ Process[R])(implicit arg0: Message[I1], arg1: Message[R]): Connections1x0[I1, R]

    Launch a process

    Launch a process

    f

    a function that binds a process to its channels.

    returns

    the connections

  32. final def launch[R](process: Process[R])(implicit arg0: Message[R]): RIChan[R]

    Launch a process

    Launch a process

    process

    a process.

    returns

    the result channel

  33. final def launch[R](process: Process[R], rc: ROChan[R])(implicit arg0: Message[R]): Unit

    Launch a process.

    Launch a process.

    process

    a process.

    rc

    the return channel.

    returns

    unit

  34. def log(msg: ⇒ String): Unit

  35. def logDbg(msg: ⇒ String): Unit

  36. def logErr(msg: String): Unit

  37. def logWarn(msg: String): Unit

  38. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  39. final def notify(): Unit

    Definition Classes
    AnyRef

  40. final def notifyAll(): Unit

    Definition Classes
    AnyRef

  41. def shutdown(): Unit

    Shutdown.

    Shutdown.

    Close all threading resources allocated by the platform.

  42. def shutdownNow(): Unit

    Shutdown and close all resources allocated by the platform.

  43. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef

  44. def toString(): String

    Definition Classes
    AnyRef → Any

  45. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws()

  46. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws()

  47. final def wait(arg0: Long): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws()

Deprecated Value Members

  1. def collect(): Unit

    Block the calling thread until all processes are terminated

    Block the calling thread until all processes are terminated

    In practice, due to race conditions, the method may be invoked before a process is launched. Therefore, for robustness one must test test that processes have terminated using their return channel before calling this method.

    Annotations
    @deprecated
    Deprecated

    (Since version 0.4) Use get_! on RIChan's instead

Inherited from Executor

Inherited from AnyRef

Inherited from Any