From 483eb2f56657e8e7f419ab1a4fab8dce9ade8609 Mon Sep 17 00:00:00 2001 From: Daniel Baumann Date: Sat, 27 Apr 2024 20:24:20 +0200 Subject: Adding upstream version 14.2.21. Signed-off-by: Daniel Baumann --- src/boost/libs/lockfree/examples/Jamfile.v2 | 13 +++++ src/boost/libs/lockfree/examples/queue.cpp | 69 ++++++++++++++++++++++++ src/boost/libs/lockfree/examples/spsc_queue.cpp | 62 ++++++++++++++++++++++ src/boost/libs/lockfree/examples/stack.cpp | 70 +++++++++++++++++++++++++ 4 files changed, 214 insertions(+) create mode 100644 src/boost/libs/lockfree/examples/Jamfile.v2 create mode 100644 src/boost/libs/lockfree/examples/queue.cpp create mode 100644 src/boost/libs/lockfree/examples/spsc_queue.cpp create mode 100644 src/boost/libs/lockfree/examples/stack.cpp (limited to 'src/boost/libs/lockfree/examples') diff --git a/src/boost/libs/lockfree/examples/Jamfile.v2 b/src/boost/libs/lockfree/examples/Jamfile.v2 new file mode 100644 index 00000000..1868a4d2 --- /dev/null +++ b/src/boost/libs/lockfree/examples/Jamfile.v2 @@ -0,0 +1,13 @@ +# (C) Copyright 2009: Tim Blechmann +# Distributed under the Boost Software License, Version 1.0. +# (See accompanying file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt) + +project boost/lockfree/example + : requirements + ../../thread/build//boost_thread/ + ../../atomic/build//boost_atomic + ; + +exe queue : queue.cpp ; +exe stack : stack.cpp ; +exe spsc_queue : spsc_queue.cpp ; diff --git a/src/boost/libs/lockfree/examples/queue.cpp b/src/boost/libs/lockfree/examples/queue.cpp new file mode 100644 index 00000000..9e599dbb --- /dev/null +++ b/src/boost/libs/lockfree/examples/queue.cpp @@ -0,0 +1,69 @@ +// Copyright (C) 2009 Tim Blechmann +// +// Distributed under the Boost Software License, Version 1.0. (See +// accompanying file LICENSE_1_0.txt or copy at +// http://www.boost.org/LICENSE_1_0.txt) + +//[queue_example +#include +#include +#include + +#include + +boost::atomic_int producer_count(0); +boost::atomic_int consumer_count(0); + +boost::lockfree::queue queue(128); + +const int iterations = 10000000; +const int producer_thread_count = 4; +const int consumer_thread_count = 4; + +void producer(void) +{ + for (int i = 0; i != iterations; ++i) { + int value = ++producer_count; + while (!queue.push(value)) + ; + } +} + +boost::atomic done (false); +void consumer(void) +{ + int value; + while (!done) { + while (queue.pop(value)) + ++consumer_count; + } + + while (queue.pop(value)) + ++consumer_count; +} + +int main(int argc, char* argv[]) +{ + using namespace std; + cout << "boost::lockfree::queue is "; + if (!queue.is_lock_free()) + cout << "not "; + cout << "lockfree" << endl; + + boost::thread_group producer_threads, consumer_threads; + + for (int i = 0; i != producer_thread_count; ++i) + producer_threads.create_thread(producer); + + for (int i = 0; i != consumer_thread_count; ++i) + consumer_threads.create_thread(consumer); + + producer_threads.join_all(); + done = true; + + consumer_threads.join_all(); + + cout << "produced " << producer_count << " objects." << endl; + cout << "consumed " << consumer_count << " objects." << endl; +} +//] diff --git a/src/boost/libs/lockfree/examples/spsc_queue.cpp b/src/boost/libs/lockfree/examples/spsc_queue.cpp new file mode 100644 index 00000000..6c6adc17 --- /dev/null +++ b/src/boost/libs/lockfree/examples/spsc_queue.cpp @@ -0,0 +1,62 @@ +// Copyright (C) 2009 Tim Blechmann +// +// Distributed under the Boost Software License, Version 1.0. (See +// accompanying file LICENSE_1_0.txt or copy at +// http://www.boost.org/LICENSE_1_0.txt) + +//[spsc_queue_example +#include +#include +#include + +#include + +int producer_count = 0; +boost::atomic_int consumer_count (0); + +boost::lockfree::spsc_queue > spsc_queue; + +const int iterations = 10000000; + +void producer(void) +{ + for (int i = 0; i != iterations; ++i) { + int value = ++producer_count; + while (!spsc_queue.push(value)) + ; + } +} + +boost::atomic done (false); + +void consumer(void) +{ + int value; + while (!done) { + while (spsc_queue.pop(value)) + ++consumer_count; + } + + while (spsc_queue.pop(value)) + ++consumer_count; +} + +int main(int argc, char* argv[]) +{ + using namespace std; + cout << "boost::lockfree::queue is "; + if (!spsc_queue.is_lock_free()) + cout << "not "; + cout << "lockfree" << endl; + + boost::thread producer_thread(producer); + boost::thread consumer_thread(consumer); + + producer_thread.join(); + done = true; + consumer_thread.join(); + + cout << "produced " << producer_count << " objects." << endl; + cout << "consumed " << consumer_count << " objects." << endl; +} +//] diff --git a/src/boost/libs/lockfree/examples/stack.cpp b/src/boost/libs/lockfree/examples/stack.cpp new file mode 100644 index 00000000..ba123026 --- /dev/null +++ b/src/boost/libs/lockfree/examples/stack.cpp @@ -0,0 +1,70 @@ +// Copyright (C) 2009 Tim Blechmann +// +// Distributed under the Boost Software License, Version 1.0. (See +// accompanying file LICENSE_1_0.txt or copy at +// http://www.boost.org/LICENSE_1_0.txt) + +//[stack_example +#include +#include +#include + +#include + +boost::atomic_int producer_count(0); +boost::atomic_int consumer_count(0); + +boost::lockfree::stack stack(128); + +const int iterations = 1000000; +const int producer_thread_count = 4; +const int consumer_thread_count = 4; + +void producer(void) +{ + for (int i = 0; i != iterations; ++i) { + int value = ++producer_count; + while (!stack.push(value)) + ; + } +} + +boost::atomic done (false); + +void consumer(void) +{ + int value; + while (!done) { + while (stack.pop(value)) + ++consumer_count; + } + + while (stack.pop(value)) + ++consumer_count; +} + +int main(int argc, char* argv[]) +{ + using namespace std; + cout << "boost::lockfree::stack is "; + if (!stack.is_lock_free()) + cout << "not "; + cout << "lockfree" << endl; + + boost::thread_group producer_threads, consumer_threads; + + for (int i = 0; i != producer_thread_count; ++i) + producer_threads.create_thread(producer); + + for (int i = 0; i != consumer_thread_count; ++i) + consumer_threads.create_thread(consumer); + + producer_threads.join_all(); + done = true; + + consumer_threads.join_all(); + + cout << "produced " << producer_count << " objects." << endl; + cout << "consumed " << consumer_count << " objects." << endl; +} +//] -- cgit v1.2.3