Lines Matching defs:Event
63 // encapsulates an event for a channel
64 static class Event {
68 Event(PollableChannel channel, int events) {
78 // event
79 private final ArrayBlockingQueue<Event> queue;
80 private final Event NEED_TO_POLL = new Event(null, 0);
81 private final Event EXECUTE_TASK_OR_SHUTDOWN = new Event(null, 0);
106 // create the queue and offer the special event to ensure that the first
108 this.queue = new ArrayBlockingQueue<Event>(MAX_EPOLL_EVENTS);
187 * event is used to signal one consumer to re-poll when all events have
191 private Event poll() throws IOException {
199 * event is handled by this thread (and so is not queued).
214 // queue special event if there are more events
226 Event ev = new Event(channel, events);
253 Event ev;
291 // process event
