Method remove_elapsed_dispatchers

implementation/runtime/src/application_impl.cpp:1852–1876

}

void application_impl::remove_elapsed_dispatchers(std::unique_lock<std::mutex>& _lock) {
    std::vector<std::shared_ptr<std::thread>> elapsed;
    if (!is_dispatching_) {
        return;
    }
    for (auto id : elapsed_dispatchers_) {
        auto it = dispatchers_.find(id);
        if (it != dispatchers_.end()) {
            elapsed.push_back(it->second);
            dispatchers_.erase(it);
        }
    }
    elapsed_dispatchers_.clear();

    for (auto& dispatcher : elapsed) {
        const auto id = dispatcher->get_id();
        VSOMEIP_INFO << "Joining dispatcher thread. client=" << hex4(client_) << " id=" << std::hex << id;
        _lock.unlock();
        if (dispatcher->joinable()) {
            dispatcher->join();
        }
        _lock.lock();
        VSOMEIP_INFO << "Joined dispatcher thread. client=" << hex4(client_) << " id=" << std::hex << id;
    }
}

void application_impl::clear_all_handler() {
    unregister_state_handler();