[Boost-commit] svn:boost r55612 - sandbox/task/libs/task/examples

Subject: [Boost-commit] svn:boost r55612 - sandbox/task/libs/task/examples
From: oliver.kowalke_at_[hidden]
Date: 2009-08-16 09:08:02

Author: olli
Date: 2009-08-16 09:08:01 EDT (Sun, 16 Aug 2009)
New Revision: 55612
URL: http://svn.boost.org/trac/boost/changeset/55612

Log:
- missing headers added

Added:
   sandbox/task/libs/task/examples/buffer.hpp   (contents, props changed)
   sandbox/task/libs/task/examples/semaphore.hpp   (contents, props changed)

Added: sandbox/task/libs/task/examples/buffer.hpp
==============================================================================
--- (empty file)
+++ sandbox/task/libs/task/examples/buffer.hpp	2009-08-16 09:08:01 EDT (Sun, 16 Aug 2009)
@@ -0,0 +1,59 @@
+
+//          Copyright Oliver Kowalke 2009.
+// 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)
+
+#ifndef BOOST_TASK_EXAMPLES_BUFFER_H
+#define BOOST_TASK_EXAMPLES_BUFFER_H
+
+#include <cstdlib>
+#include <string>
+
+#include <boost/assert.hpp>
+#include <boost/lexical_cast.hpp>
+#include <boost/optional.hpp>
+
+#include "boost/task.hpp"
+
+namespace tsk = boost::task;
+
+inline
+void send_ping(
+		int n,
+		tsk::unbounded_buffer< std::string > & buf_ping,
+		tsk::unbounded_buffer< std::string > & buf_pong)
+{
+	for ( int i = 0; i < n; ++i)
+	{
+		printf("task 1: buf_ping.put(%d-th ping)\n", i);
+		buf_ping.put(
+				boost::lexical_cast< std::string >( i) + "-th ping");
+		boost::optional< std::string > msg;
+	   	buf_pong.take( msg);
+		BOOST_ASSERT( msg);
+		printf("task 1: buf_pong.take(%s)\n", msg->c_str() );
+	}
+	printf("task 1: end\n");
+}
+
+inline
+void send_pong(
+		int n,
+		tsk::unbounded_buffer< std::string > & buf_ping,
+		tsk::unbounded_buffer< std::string > & buf_pong)
+{
+	for ( int i = 0; i < n; ++i)
+	{
+		printf("task 2: buf_pong.put(%d-th pong)\n", i);
+		buf_pong.put(
+				boost::lexical_cast< std::string >( i) + "-th pong");
+		boost::optional< std::string > msg;
+	   	buf_ping.take( msg);
+		BOOST_ASSERT( msg);
+		printf("task 2: buf_ping.take(%s)\n", msg->c_str() );
+	}
+	printf("task 2: end\n");
+}
+
+#endif // BOOST_TASK_EXAMPLES_BUFFER_H

Added: sandbox/task/libs/task/examples/semaphore.hpp
==============================================================================
--- (empty file)
+++ sandbox/task/libs/task/examples/semaphore.hpp	2009-08-16 09:08:01 EDT (Sun, 16 Aug 2009)
@@ -0,0 +1,64 @@
+
+//          Copyright Oliver Kowalke 2009.
+// 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)
+
+#ifndef BOOST_TASK_EXAMPLES_SEMAPHORE_H
+#define BOOST_TASK_EXAMPLES_SEMAPHORE_H
+
+#include <iostream>
+#include <cstdlib>
+#include <stdexcept>
+
+#include <boost/bind.hpp>
+#include <boost/ref.hpp>
+
+#include "boost/task.hpp"
+
+namespace tsk = boost::task;
+
+inline
+void loop_fn( int n)
+{
+	for ( int i = 0; i < n; ++i)
+	{
+		printf("task 3: %d-th iteration\n", i);
+		boost::this_task::block();
+	}
+	printf("task 3: end\n");
+}
+
+inline
+void start_with_sem_a(
+		int n,
+		tsk::semaphore & sem_a,
+		tsk::semaphore & sem_b)
+{
+	for ( int i = 0; i < n; ++i)
+	{
+		printf("task 1: %d-th sema_a.post()\n", i);
+		sem_a.post();
+		printf("task 1: %d-th sema_b.wait()\n", i);
+		sem_b.wait();
+	}
+	printf("task 1: end\n");
+}
+
+inline
+void start_with_sem_b(
+		int n,
+		tsk::semaphore & sem_a,
+		tsk::semaphore & sem_b)
+{
+	for ( int i = 0; i < n; ++i)
+	{
+		printf("task 2: %d-th sema_b.post()\n", i);
+		sem_b.post();
+		printf("task 2: %d-th sema_a.wait()\n", i);
+		sem_a.wait();
+	}
+	printf("task 2: end\n");
+}
+
+#endif // BOOST_TASK_EXAMPLES_SEMAPHORE_H