@Override public void run() {
        try {
            while (true) {
                Runnable r = deque.takeFirst();

                if (leavingNestedEventLoop) {
                    // Defer invocation of the runnable till the current inner
                    // event loop returns from its enterNestedEventLoop()
                    deque.addFirst(r);
                    synchronized (LOCK) {
                        while (leavingNestedEventLoop) {
                            LOCK.wait();
                        }
                    }
                } else {
                    // Submit the runnable to the native system
                    final Future future = new Future(r);
                    invokeLaterSubmitter.submitForLaterInvocation(future);
                    synchronized (LOCK) {
                        try {
                            while (!future.isDone() && !nestedEventLoopEntered) {
                                LOCK.wait();
                            }
                            // Continue processing other runnables if we entered
                            // an inner event loop while excuting this runnable
                        } finally {
                            nestedEventLoopEntered = false;
                        }
                    }
                }
            }
        } catch (InterruptedException ex) {
            // OK, let's stop this thread
        }
    }