Subject: [Boost-commit] svn:boost r58320 - sandbox/fiber/libs/fiber/examples
From: oliver.kowalke_at_[hidden]
Date: 2009-12-12 05:05:37
Author: olli
Date: 2009-12-12 05:05:36 EST (Sat, 12 Dec 2009)
New Revision: 58320
URL: http://svn.boost.org/trac/boost/changeset/58320
Log:
added
Added:
sandbox/fiber/libs/fiber/examples/future_mt.cpp (contents, props changed)
Text files modified:
sandbox/fiber/libs/fiber/examples/future.cpp | 45 +++------------------------------------
1 files changed, 4 insertions(+), 41 deletions(-)
Modified: sandbox/fiber/libs/fiber/examples/future.cpp
==============================================================================
--- sandbox/fiber/libs/fiber/examples/future.cpp (original)
+++ sandbox/fiber/libs/fiber/examples/future.cpp 2009-12-12 05:05:36 EST (Sat, 12 Dec 2009)
@@ -8,58 +8,21 @@
#include <boost/thread.hpp>
#include <boost/fiber.hpp>
+#include <boost/fiber/spin/future.hpp>
inline
std::string helloworld_fn()
{ return "Hello World"; }
-class callable
-{
-private:
- struct impl
- {
- virtual ~impl() {}
-
- virtual void exec() = 0;
- };
-
- template< typename T >
- class timpl : public impl
- {
- private:
- boost::packaged_task< T > pt_;
-
- public:
- timpl( boost::packaged_task< T > & pt) :
- pt_( boost::move( pt) )
- {}
-
- void exec()
- { pt_(); }
- };
-
- boost::shared_ptr< impl > impl_;
-
-public:
- template< typename T >
- callable( boost::packaged_task< T > & pt) :
- impl_( new timpl< T >( pt) )
- {}
-
- void operator()()
- { impl_->exec(); }
-};
-
int main()
{
try
{
boost::fibers::scheduler<> sched;
- boost::packaged_task< std::string > pt( helloworld_fn);
- boost::unique_future< std::string > fu = pt.get_future();
- callable ca( pt);
- sched.make_fiber( ca);
+ boost::fibers::spin::packaged_task< std::string > pt( helloworld_fn);
+ boost::fibers::spin::unique_future< std::string > fu = pt.get_future();
+ sched.make_fiber( boost::move( pt) );
for (;;)
{
Added: sandbox/fiber/libs/fiber/examples/future_mt.cpp
==============================================================================
--- (empty file)
+++ sandbox/fiber/libs/fiber/examples/future_mt.cpp 2009-12-12 05:05:36 EST (Sat, 12 Dec 2009)
@@ -0,0 +1,170 @@
+#include <cstdlib>
+#include <iostream>
+#include <sstream>
+#include <string>
+
+#include <boost/bind.hpp>
+#include <boost/shared_ptr.hpp>
+#include <boost/system/system_error.hpp>
+#include <boost/thread.hpp>
+
+#include <boost/fiber.hpp>
+#include <boost/fiber/spin/future.hpp>
+
+class callable
+{
+private:
+ struct impl
+ {
+ virtual ~impl() {}
+
+ virtual void exec() = 0;
+ };
+
+ template< typename T >
+ class timpl : public impl
+ {
+ private:
+ boost::fibers::spin::packaged_task< T > pt_;
+
+ public:
+ timpl( boost::fibers::spin::packaged_task< T > & pt) :
+ pt_( boost::move( pt) )
+ {}
+
+ void exec()
+ { pt_(); }
+ };
+
+ boost::shared_ptr< impl > impl_;
+
+public:
+ template< typename T >
+ callable( boost::fibers::spin::packaged_task< T > & pt) :
+ impl_( new timpl< T >( pt) )
+ {}
+
+ void operator()()
+ { impl_->exec(); }
+};
+
+int value1 = 0;
+int value2 = 0;
+
+inline
+std::string helloworld_fn()
+{
+ std::stringstream ss;
+ ss << boost::this_thread::get_id();
+
+ fprintf( stderr, "thread %s returns 'Hello World'\n", ss.str().c_str() );
+ return "Hello World";
+}
+
+void increment_fn1()
+{
+ std::stringstream ss;
+ ss << boost::this_thread::get_id();
+
+ for ( int i = 0; i < 5; ++i)
+ {
+ ++value1;
+ fprintf( stderr, "thread %s incremented value1 %d\n", ss.str().c_str(), value1);
+ boost::this_fiber::yield();
+ }
+}
+
+void increment_fn2()
+{
+ std::stringstream ss;
+ ss << boost::this_thread::get_id();
+
+ for ( int i = 0; i < 3; ++i)
+ {
+ ++value2;
+ fprintf( stderr, "thread %s incremented value2 %d\n", ss.str().c_str(), value2);
+ }
+
+ ++value2;
+ fprintf( stderr, "thread %s incremented value2 %d\n", ss.str().c_str(), value2);
+ boost::this_fiber::yield();
+ ++value2;
+ fprintf( stderr, "thread %s incremented value2 %d\n", ss.str().c_str(), value2);
+ boost::this_fiber::yield();
+}
+
+void waiting_fn( boost::fibers::spin::shared_future< std::string > fu)
+{
+ std::stringstream ss;
+ ss << boost::this_thread::get_id();
+
+ fprintf( stderr, "thread %s waits for future\n", ss.str().c_str() );
+ std::string result = fu.get();
+ fprintf( stderr, "thread %s got string %s from future\n", ss.str().c_str(), result.c_str() );
+}
+
+void thread_fn1( boost::fibers::spin::shared_future< std::string > fu)
+{
+ std::stringstream ss;
+ ss << boost::this_thread::get_id();
+
+ fprintf( stderr, "thread %s started\n", ss.str().c_str() );
+
+ boost::fibers::scheduler<> sched;
+
+ sched.make_fiber( & increment_fn1);
+ sched.make_fiber( & waiting_fn, fu);
+
+ for (;;)
+ {
+ while ( sched.run() );
+ if ( sched.empty() ) break;
+ }
+ fprintf( stderr, "thread %s finished\n", ss.str().c_str() );
+}
+
+void thread_fn2( callable ca)
+{
+ std::stringstream ss;
+ ss << boost::this_thread::get_id();
+
+ fprintf( stderr, "thread %s started\n", ss.str().c_str() );
+
+ boost::fibers::scheduler<> sched;
+
+ sched.make_fiber( & increment_fn2);
+ sched.make_fiber( ca);
+
+ for (;;)
+ {
+ while ( sched.run() );
+ if ( sched.empty() ) break;
+ }
+ fprintf( stderr, "thread %s finished\n", ss.str().c_str() );
+}
+
+int main()
+{
+ try
+ {
+ boost::fibers::spin::packaged_task< std::string > pt( helloworld_fn);
+ boost::fibers::spin::unique_future< std::string > fu = pt.get_future();
+
+ boost::thread th1( boost::bind( & thread_fn1, boost::fibers::spin::shared_future< std::string >( fu) ) );
+ boost::thread th2( boost::bind( & thread_fn2, callable( pt) ) );
+
+ th1.join();
+ th2.join();
+
+ return EXIT_SUCCESS;
+ }
+ catch ( boost::system::system_error const& e)
+ { std::cerr << "system_error: " << e.code().value() << std::endl; }
+ catch ( boost::fibers::scheduler_error const& e)
+ { std::cerr << "scheduler_error: " << e.what() << std::endl; }
+ catch ( std::exception const& e)
+ { std::cerr << "exception: " << e.what() << std::endl; }
+ catch (...)
+ { std::cerr << "unhandled exception" << std::endl; }
+ return EXIT_FAILURE;
+}