#include <chrono>
#include <thread>
#include <iostream>
#include <vector>

using namespace std;

bool timeout = false;

int main (int argc, char* argv[])
{
    int delay = 0;
    if (argc == 2)
    {
        delay = atoi (argv[1]);
    }

    if (delay > 0)
    {
        cout << "Will run for: " << delay << " milliseconds." << endl;

        thread t ([&] () {
            this_thread::sleep_for (chrono::milliseconds (delay));
            timeout = true;
        });
        t.detach ();
    }
    else
    {
        cout << "Will run forever." << endl;
    }

    const int n = thread::hardware_concurrency ();
    cout << "Using " << n << " thread(s)." << endl;

    // using vector as MSVC doesn't support variable length array
    vector <thread> workers;
    workers.reserve (n);
    for (int i = 0; i < n; ++i)
    {
        workers.push_back (thread ([] () {

            // volatile is mandatory for GCC release build
            volatile int count = 0;
            while (!timeout)
            {
                count ++;
            }
        }));
    }

    for (auto &worker : workers)
    {
        worker.join ();
    }

    return 0;
}