thread_pool_bridge.h

Go to the documentation of this file.

// BSD 3-Clause License
// Copyright (c) 2021-2025, 🍀☀🌕🌥 🌊
// See the LICENSE file in the project root for full license information.
 
#pragma once
#ifndef KCENON_NETWORK_INTERNAL_INTEGRATION_THREAD_POOL_BRIDGE_H_
#define KCENON_NETWORK_INTERNAL_INTEGRATION_THREAD_POOL_BRIDGE_H_
 
#include "internal/integration/bridge_interface.h"
#include "kcenon/network/integration/thread_integration.h"
#include <kcenon/network/detail/config/feature_flags.h>
#include <memory>
#include <string>
#include <mutex>
#include <atomic>
 
#if KCENON_WITH_COMMON_SYSTEM
#include <kcenon/common/interfaces/executor_interface.h>
#endif
 
namespace kcenon::network::integration {
 
class ThreadPoolBridge : public INetworkBridge {
public:
    enum class BackendType {
        ThreadSystem,  
        CommonSystem,  
        Custom         
    };
 
    explicit ThreadPoolBridge(
        std::shared_ptr<thread_pool_interface> pool,
        BackendType backend_type = BackendType::Custom);
 
    ~ThreadPoolBridge() override;
 
    // INetworkBridge interface implementation
 
    VoidResult initialize(const BridgeConfig& config) override;
 
    VoidResult shutdown() override;
 
    bool is_initialized() const override;
 
    BridgeMetrics get_metrics() const override;
 
    // ThreadPoolBridge-specific methods
 
    std::shared_ptr<thread_pool_interface> get_thread_pool() const;
 
    BackendType get_backend_type() const;
 
    // Factory methods
 
    static std::shared_ptr<ThreadPoolBridge> from_thread_system(
        const std::string& pool_name = "network_pool");
 
#if KCENON_WITH_COMMON_SYSTEM
    static std::shared_ptr<ThreadPoolBridge> from_common_system(
        std::shared_ptr<::kcenon::common::interfaces::IExecutor> executor);
#endif
 
private:
    std::shared_ptr<thread_pool_interface> pool_;
    BackendType backend_type_;
    std::atomic<bool> initialized_{false};
    mutable std::mutex metrics_mutex_;
    mutable BridgeMetrics cached_metrics_;
};
 
} // namespace kcenon::network::integration
 
// Backward compatibility namespace alias
namespace network_system {
    namespace integration = kcenon::network::integration;
}
 
#endif // KCENON_NETWORK_INTERNAL_INTEGRATION_THREAD_POOL_BRIDGE_H_