main.cpp

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.
 
#include <iostream>
#include <memory>
#include <thread>
#include <atomic>
 
#include <kcenon/thread/core/service_registry.h>
#include <kcenon/thread/core/thread_pool.h>
#include <kcenon/thread/core/thread_worker.h>
#include <kcenon/thread/core/callback_job.h>
 
using namespace kcenon::thread;
 
struct demo_service {
    std::string name;
};
 
int main() {
    // Register and get a simple service
    auto svc = std::make_shared<demo_service>();
    svc->name = "demo";
    service_registry::register_service<demo_service>(svc);
    auto got = service_registry::get_service<demo_service>();
    std::cout << "service name = " << (got ? got->name : "<null>") << "\n";
 
    // Use thread_pool directly (not via deprecated executor_interface)
    auto pool = std::make_shared<thread_pool>("svc_pool");
    std::vector<std::unique_ptr<thread_worker>> workers;
    workers.push_back(std::make_unique<thread_worker>(false));
    if (auto r = pool->enqueue_batch(std::move(workers)); r.is_err()) {
        std::cerr << r.error().message << "\n";
        return 1;
    }
    if (auto r = pool->start(); r.is_err()) {
        std::cerr << r.error().message << "\n";
        return 1;
    }
 
    std::atomic<int> count{0};
    if (auto r = pool->enqueue(std::make_unique<callback_job>([&count]() -> kcenon::common::VoidResult {
            count.fetch_add(1);
            return kcenon::common::ok();
        })); r.is_err()) {
        std::cerr << r.error().message << "\n";
    }
 
    std::this_thread::sleep_for(std::chrono::milliseconds(50));
    std::cout << "executed jobs = " << count.load() << "\n";
    pool->stop();
    return 0;
}