Method handler

valdi_core/src/valdi_core/cpp/Threading/ThreadedDispatchQueue.cpp:142–173

}

void ThreadedDispatchQueue::handler(ThreadedDispatchQueue* dispatchQueue, const Ref<TaskQueue>& taskQueue) {
    current = dispatchQueue;

    while (!taskQueue->isDisposed()) {
#if TARGET_OS_IPHONE
        auto pool = objc_autoreleasePoolPush();

        // On Apple systems, every thread (even C++ threads) come with a CFRunLoop attached.
        // Some system libraries, like JavaScriptCore pushes timers onto the CFRunLoop.
        // We therefore need to flush manually our CFRunLoop as well as our TaskQueue.

        auto nextFireDate = CFRunLoopGetNextTimerFireDate(CFRunLoopGetCurrent(), kCFRunLoopDefaultMode);
        if (nextFireDate == 0.0) {
            // Nothing in the run loop, we can loop semi-indefinitely.
            taskQueue->runNextTask(std::chrono::steady_clock::now() + std::chrono::seconds(10000000));
        } else {
            auto timeToWaitSeconds = std::max(nextFireDate - CFAbsoluteTimeGetCurrent(), 0.0);
            // We have something in the runloop, we need to cap our wait to the next task in the CFRunLoop.
            taskQueue->runNextTask(std::chrono::steady_clock::now() +
                                   std::chrono::nanoseconds(static_cast<long long>(timeToWaitSeconds * 1000000000)));
        }

        // Flush the CFRunLoop
        while (CFRunLoopRunInMode(kCFRunLoopDefaultMode, 0, true) == kCFRunLoopRunHandledSource) {
        }

        objc_autoreleasePoolPop(pool);
#else
        taskQueue->runNextTask(std::chrono::steady_clock::now() + std::chrono::seconds(100000));
#endif
    }
}

bool ThreadedDispatchQueue::isCurrent() const {
    return this == getCurrent();