()
| 188 | } |
| 189 | |
| 190 | public void wakeup() { |
| 191 | int selectTimeout = selectors.getSelectTimeout(); |
| 192 | if (selectTimeout <= 0 && Thread.currentThread() != this && wakeupNotified.compareAndSet(0, 1)) { |
| 193 | // wakeupCount1.incrementAndGet(); |
| 194 | // long t = System.nanoTime(); |
| 195 | if (selectTimeout == 0) |
| 196 | selector.wakeup(); |
| 197 | else |
| 198 | WakeupThread.postWakeup(selector); |
| 199 | // wakeupTime.addAndGet(System.nanoTime() - t); |
| 200 | }// else |
| 201 | // wakeupCount0.incrementAndGet(); |
| 202 | } |
| 203 | |
| 204 | @Override |
| 205 | public void run() { |
no test coverage detected