< prev index next >

src/java.base/linux/classes/sun/nio/ch/EPollPort.java

Print this page

        

*** 103,113 **** // allocate the poll array this.address = allocatePollArray(MAX_EPOLL_EVENTS); // create the queue and offer the special event to ensure that the first // threads polls ! this.queue = new ArrayBlockingQueue<Event>(MAX_EPOLL_EVENTS); this.queue.offer(NEED_TO_POLL); } EPollPort start() { startThreads(new EventHandlerTask()); --- 103,113 ---- // allocate the poll array this.address = allocatePollArray(MAX_EPOLL_EVENTS); // create the queue and offer the special event to ensure that the first // threads polls ! this.queue = new ArrayBlockingQueue<>(MAX_EPOLL_EVENTS); this.queue.offer(NEED_TO_POLL); } EPollPort start() { startThreads(new EventHandlerTask());
< prev index next >