Java 类io.netty.util.concurrent.AbstractScheduledEventExecutor 实例源码

项目：open-kilda 文件：TestEventLoop.java

long runScheduledTasks() {
    long time = AbstractScheduledEventExecutor.nanoTime();
    for (;;) {
        Runnable task = pollScheduledTask(time);
        if (task == null) {
            return nextScheduledTaskNano();
        }

        task.run();
    }
}

项目：fresco_floodlight 文件：TestEventLoop.java

long runScheduledTasks() {
    long time = AbstractScheduledEventExecutor.nanoTime();
    for (;;) {
        Runnable task = pollScheduledTask(time);
        if (task == null) {
            return nextScheduledTaskNano();
        }

        task.run();
    }
}

项目：SDN-Multicast 文件：TestEventLoop.java

long runScheduledTasks() {
    long time = AbstractScheduledEventExecutor.nanoTime();
    for (;;) {
        Runnable task = pollScheduledTask(time);
        if (task == null) {
            return nextScheduledTaskNano();
        }

        task.run();
    }
}

项目：arscheduler 文件：TestEventLoop.java

long runScheduledTasks() {
    long time = AbstractScheduledEventExecutor.nanoTime();
    for (;;) {
        Runnable task = pollScheduledTask(time);
        if (task == null) {
            return nextScheduledTaskNano();
        }

        task.run();
    }
}

项目：floodlight1.2-delay 文件：TestEventLoop.java

long runScheduledTasks() {
    long time = AbstractScheduledEventExecutor.nanoTime();
    for (;;) {
        Runnable task = pollScheduledTask(time);
        if (task == null) {
            return nextScheduledTaskNano();
        }

        task.run();
    }
}

项目：floodlight-hardware 文件：TestEventLoop.java

long runScheduledTasks() {
    long time = AbstractScheduledEventExecutor.nanoTime();
    for (;;) {
        Runnable task = pollScheduledTask(time);
        if (task == null) {
            return nextScheduledTaskNano();
        }

        task.run();
    }
}

项目：ACAMPController 文件：TestEventLoop.java

long runScheduledTasks() {
    long time = AbstractScheduledEventExecutor.nanoTime();
    for (;;) {
        Runnable task = pollScheduledTask(time);
        if (task == null) {
            return nextScheduledTaskNano();
        }

        task.run();
    }
}

项目：netty4.0.27Learn 文件：EmbeddedEventLoop.java

long runScheduledTasks() {
    long time = AbstractScheduledEventExecutor.nanoTime();
    for (;;) {
        Runnable task = pollScheduledTask(time);
        if (task == null) {
            return nextScheduledTaskNano();
        }

        task.run();
    }
}