main.cpp File Reference

Service registry sample showing singleton service registration and thread pool usage. More...

#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>

Include dependency graph for main.cpp:

Go to the source code of this file.

Classes
struct	demo_service

Functions
int	main ()

Detailed Description

Service registry sample showing singleton service registration and thread pool usage.

Definition in file main.cpp.

Function Documentation

main()

int main

(

)

Definition at line 32 of file main.cpp.

           {
    // 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;
}

References kcenon::thread::service_registry::get_service(), and kcenon::thread::service_registry::register_service().

Here is the call graph for this function: