initial commit

Author: Tectu

.gitignore

@@ -0,0 +1,93 @@
+# Created by https://www.toptal.com/developers/gitignore/api/clion+all
+# Edit at https://www.toptal.com/developers/gitignore?templates=clion+all
+
+### CLion+all ###
+# Covers JetBrains IDEs: IntelliJ, RubyMine, PhpStorm, AppCode, PyCharm, CLion, Android Studio, WebStorm and Rider
+# Reference: https://intellij-support.jetbrains.com/hc/en-us/articles/206544839
+
+# User-specific stuff
+.idea/**/workspace.xml
+.idea/**/tasks.xml
+.idea/**/usage.statistics.xml
+.idea/**/dictionaries
+.idea/**/shelf
+
+# AWS User-specific
+.idea/**/aws.xml
+
+# Generated files
+.idea/**/contentModel.xml
+
+# Sensitive or high-churn files
+.idea/**/dataSources/
+.idea/**/dataSources.ids
+.idea/**/dataSources.local.xml
+.idea/**/sqlDataSources.xml
+.idea/**/dynamic.xml
+.idea/**/uiDesigner.xml
+.idea/**/dbnavigator.xml
+
+# Gradle
+.idea/**/gradle.xml
+.idea/**/libraries
+
+# Gradle and Maven with auto-import
+# When using Gradle or Maven with auto-import, you should exclude module files,
+# since they will be recreated, and may cause churn.  Uncomment if using
+# auto-import.
+# .idea/artifacts
+# .idea/compiler.xml
+# .idea/jarRepositories.xml
+# .idea/modules.xml
+# .idea/*.iml
+# .idea/modules
+# *.iml
+# *.ipr
+
+# CMake
+cmake-build-*/
+
+# Mongo Explorer plugin
+.idea/**/mongoSettings.xml
+
+# File-based project format
+*.iws
+
+# IntelliJ
+out/
+
+# mpeltonen/sbt-idea plugin
+.idea_modules/
+
+# JIRA plugin
+atlassian-ide-plugin.xml
+
+# Cursive Clojure plugin
+.idea/replstate.xml
+
+# SonarLint plugin
+.idea/sonarlint/
+
+# Crashlytics plugin (for Android Studio and IntelliJ)
+com_crashlytics_export_strings.xml
+crashlytics.properties
+crashlytics-build.properties
+fabric.properties
+
+# Editor-based Rest Client
+.idea/httpRequests
+
+# Android studio 3.1+ serialized cache file
+.idea/caches/build_file_checksums.ser
+
+### CLion+all Patch ###
+# Ignore everything but code style settings and run configurations
+# that are supposed to be shared within teams.
+
+.idea/*
+
+!.idea/codeStyles
+!.idea/runConfigurations
+
+# End of https://www.toptal.com/developers/gitignore/api/clion+all
+

CMakeLists.txt

@@ -0,0 +1,29 @@
+cmake_minimum_required(VERSION 3.24)
+
+project(
+    thread_pool
+    LANGUAGES
+        CXX
+)
+
+set(TARGET thread-pool)
+add_executable(${TARGET})
+
+target_compile_features(
+    ${TARGET}
+    PUBLIC
+        cxx_std_20
+)
+
+target_sources(
+    ${TARGET}
+    PRIVATE
+        main.cpp
+        thread_pool.hpp
+)
+
+target_link_libraries(
+    ${TARGET}
+    PRIVATE
+        pthread
+)

main.cpp

@@ -0,0 +1,56 @@
+#include <chrono>
+#include <iostream>
+
+#include "thread_pool.hpp"
+
+using namespace jbo;
+
+int
+long_running_task()
+{
+    using namespace std::chrono_literals;
+
+    std::this_thread::sleep_for(5s);
+
+    return 4;
+}
+
+void
+print_state(const thread_pool::status& s, std::ostream& out = std::cout)
+{
+    std::cout << "pool size : " << s.pool_size << "\n";
+    std::cout << "queue size: " << s.queue_size << "\n";
+    for (std::size_t i = 0; i < s.thread_states.size(); i++)
+        std::cout << "thread [" << i << "] state: " << static_cast<int>(s.thread_states[i]) << "\n";
+}
+
+int
+main()
+{
+    thread_pool tp(4);
+
+    std::vector<std::future<int>> results;
+    for (std::size_t i = 0; i < 10; i++) {
+
+        auto future = tp.enqueue([i]() -> int {
+            std::this_thread::sleep_for(std::chrono::seconds(1));
+            return i * i;
+        });
+
+        results.emplace_back(std::move(future));
+    }
+
+    for (int i = 0; i < 10; i++) {
+        print_state(tp.get_status());
+        std::cout << std::endl;
+        std::this_thread::sleep_for(std::chrono::milliseconds(250));
+    }
+
+    std::cout << "waiting..." << std::endl;
+    for (auto& result : results)
+        std::cout << "result: "  << result.get() << std::endl;
+
+    while (true)
+        std::this_thread::sleep_for(std::chrono::seconds(1));
+    return EXIT_SUCCESS;
+}