final class SelectorSystem extends PollingSystem
- Source
- SelectorSystem.scala
- Alphabetic
- By Inheritance
- SelectorSystem
- PollingSystem
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
- type Api = Selector
The user-facing interface.
The user-facing interface.
- Definition Classes
- SelectorSystem → PollingSystem
- final class Poller extends PollerMetrics
- final class SelectorImpl extends Selector
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- def close(): Unit
Closes the polling system.
Closes the polling system.
- Definition Classes
- SelectorSystem → PollingSystem
- def closePoller(poller: Poller): Unit
Closes a specific poller.
Closes a specific poller.
- poller
the poller to be closed.
- Definition Classes
- SelectorSystem → PollingSystem
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def interrupt(targetThread: Thread, targetPoller: Poller): Unit
Interrupts a specific target poller running on a specific target thread.
Interrupts a specific target poller running on a specific target thread.
- targetThread
is the thread where the target poller is running.
- targetPoller
is the poller to be interrupted.
- Definition Classes
- SelectorSystem → PollingSystem
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def makeApi(ctx: PollingContext[Poller]): Selector
Creates a new instance of the user-facing interface.
Creates a new instance of the user-facing interface.
- Definition Classes
- SelectorSystem → PollingSystem
- def makePoller(): Poller
Creates a new instance of the thread-local data structure used for polling.
Creates a new instance of the thread-local data structure used for polling.
- returns
an instance of the poller
Poller
.
- Definition Classes
- SelectorSystem → PollingSystem
- def metrics(poller: Poller): PollerMetrics
Returns a handle to access metrics associated with the specified poller.
Returns a handle to access metrics associated with the specified poller.
The returned
PollerMetrics
provides access to live counts of submitted, succeeded, errored, and canceled operations for accept, connect, read, and write events. It also includes counts of outstanding operations and the total number of operations.- poller
The poller for which the metrics handle is being retrieved.
- returns
A
PollerMetrics
instance that can be used to query the current metrics for the poller.
- Definition Classes
- SelectorSystem → PollingSystem
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def needsPoll(poller: Poller): Boolean
- returns
whether poll should be called again (i.e., there are more events to be polled)
- Definition Classes
- SelectorSystem → PollingSystem
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- def poll(poller: Poller, nanos: Long): PollResult
Blocks the thread until an event is polled, the timeout expires, or interrupted.
Blocks the thread until an event is polled, the timeout expires, or interrupted.
- poller
the thread-local Poller used to poll events.
- nanos
the maximum duration for which to block, where
nanos == -1
indicates to block indefinitely.- returns
whether any ready events were polled and should be handled with processReadyEvents. If result is incomplete, then poll should be called again after processReadyEvents.
- Definition Classes
- SelectorSystem → PollingSystem
- def processReadyEvents(poller: Poller): Boolean
Processes ready events e.g.
Processes ready events e.g. collects their results and resumes the corresponding tasks.
- poller
the thread-local Poller with ready events
- returns
whether any of the ready events caused tasks to be rescheduled on the runtime
- Definition Classes
- SelectorSystem → PollingSystem
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()