Modifier and Type	Class and Description
private static class	VirtualThreadPollerNaive.PollJob

Field Summary

Modifier and Type	Field and Description
private static final InterruptedIOException	POLL_INTERRUPTED_SENTINEL
private static final int	POLL_INTERVAL_MILLIS
private static final Map<FileDescriptor, VirtualThreadPollerNaive.PollJob>	POLL_JOBS

Access	Constructor and Description
pack-priv	VirtualThreadPollerNaive()

Method Summary

Modifier and Type Method and Description

Modifier and Type	Method and Description
public void	parkThreadUntilReady(FileDescriptor The file descriptor to check. fd, int The mode (bitmask of `SelectionKey#OP_READ`, `SelectionKey#OP_WRITE`, `SelectionKey#OP_ACCEPT`, `SelectionKey#OP_CONNECT`) mode, long The refence time (in millis) for the timeout now, AFSupplier<Integer> (in seconds), or 0 for infinite timeout, Closeable Callback to call upon interrupt (usually to close the resource working on the file descriptor) closeOnInterrupt) Implements org.newsclub.net.unix.VirtualThreadPoller.parkThreadUntilReady. Parks the current thread until the given file descriptor is ready, with respect to the given readiness mode.

public void

parkThreadUntilReady(FileDescriptor

The file descriptor to check.

fd, int

The mode (bitmask of SelectionKey#OP_READ, SelectionKey#OP_WRITE, SelectionKey#OP_ACCEPT, SelectionKey#OP_CONNECT)

mode, long

The refence time (in millis) for the timeout

now, AFSupplier<Integer>

(in seconds), or 0 for infinite

timeout, Closeable

Callback to call upon interrupt (usually to close the resource working on the file descriptor)

closeOnInterrupt)

Implements org.newsclub.net.unix.VirtualThreadPoller.parkThreadUntilReady.

Parks the current thread until the given file descriptor is ready, with respect to the given readiness mode.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

POLL_INTERRUPTED_SENTINEL	back to summary
private static final InterruptedIOException POLL_INTERRUPTED_SENTINEL

POLL_INTERVAL_MILLIS	back to summary
private static final int POLL_INTERVAL_MILLIS

POLL_JOBS	back to summary
private static final Map<FileDescriptor, VirtualThreadPollerNaive.PollJob> POLL_JOBS

VirtualThreadPollerNaive	back to summary
pack-priv VirtualThreadPollerNaive()

Method Detail

parkThreadUntilReady back to summary

parkThreadUntilReady	back to summary
public void parkThreadUntilReady(FileDescriptor fd, int mode, long now, AFSupplier<Integer> timeout, Closeable closeOnInterrupt) throws IOException Implements org.newsclub.net.unix.VirtualThreadPoller.parkThreadUntilReady. Doc from org.newsclub.net.unix.VirtualThreadPoller.parkThreadUntilReady. Parks the current thread until the given file descriptor is ready, with respect to the given readiness mode. Parameters fd:FileDescriptor The file descriptor to check. mode:int The mode (bitmask of `SelectionKey#OP_READ`, `SelectionKey#OP_WRITE`, `SelectionKey#OP_ACCEPT`, `SelectionKey#OP_CONNECT`) now:long The refence time (in millis) for the timeout timeout:AFSupplier<Integer> (in seconds), or 0 for infinite closeOnInterrupt:Closeable Callback to call upon interrupt (usually to close the resource working on the file descriptor) Annotations @Override Exceptions IOException: on other error

public void parkThreadUntilReady(FileDescriptor fd, int mode, long now, AFSupplier<Integer> timeout, Closeable closeOnInterrupt) throws IOException

Implements org.newsclub.net.unix.VirtualThreadPoller.parkThreadUntilReady.

Doc from org.newsclub.net.unix.VirtualThreadPoller.parkThreadUntilReady.

Parks the current thread until the given file descriptor is ready, with respect to the given readiness mode.

Parameters

fd:FileDescriptor: The file descriptor to check.
mode:int: The mode (bitmask of SelectionKey#OP_READ, SelectionKey#OP_WRITE, SelectionKey#OP_ACCEPT, SelectionKey#OP_CONNECT)
now:long: The refence time (in millis) for the timeout
timeout:AFSupplier<Integer>: (in seconds), or 0 for infinite
closeOnInterrupt:Closeable: Callback to call upon interrupt (usually to close the resource working on the file descriptor)

Annotations

@Override

Exceptions

IOException:: on other error

org.newsclub.net.unix back to summary

private final Class VirtualThreadPollerNaive.PollJob

Class Inheritance

extends Object

java.lang.Object
org.newsclub.net.unix.VirtualThreadPollerNaive.PollJob

Field Summary

Modifier and Type	Field and Description
private final FileDescriptor	fd
private final int	mode
private final long	now
private final AFSupplier<Integer>	timeout
private final List<Thread>	waitingThreads

Constructor Summary

Access	Constructor and Description
pack-priv	PollJob(FileDescriptor fd, int mode, long now, AFSupplier<Integer> timeout)

Method Summary

Modifier and Type	Method and Description
pack-priv AFFuture<@Nullable IOException>	trigger(Thread waitingThread)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

fd	back to summary
private final FileDescriptor fd

mode	back to summary
private final int mode

now	back to summary
private final long now

timeout	back to summary
private final AFSupplier<Integer> timeout

waitingThreads	back to summary
private final List<Thread> waitingThreads

Constructor Detail

PollJob	back to summary
pack-priv PollJob(FileDescriptor fd, int mode, long now, AFSupplier<Integer> timeout)

Method Detail

trigger	back to summary
pack-priv AFFuture<@Nullable IOException> trigger(Thread waitingThread) Annotations @SuppressWarnings:PMD.CognitiveComplexity

pack-priv final Class VirtualThreadPollerNaive

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private final Class VirtualThreadPollerNaive.PollJob

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail