change VLOG(2) to VLOG(3)

src/experimental/SConscript

@@ -6,6 +6,8 @@ experimental_env.Append(LIBS=[
 	'gflags',
 	'glog',
 	'gtest',
+	'boost_system'
 ])
 
-experimental_env.Program('boost_function_test.cc')
+experimental_env.Program('boost_function_test.cc')
+experimental_env.Program('boost_asio_test.cc')

src/experimental/boost_asio_test.cc

@@ -0,0 +1,63 @@
+#include <iostream>
+#include <boost/asio.hpp>
+#include <boost/thread.hpp>
+#include <boost/bind.hpp>
+#include <boost/date_time/posix_time/posix_time.hpp>
+
+class printer
+{
+public:
+	printer(boost::asio::io_service& io) :
+		strand_(io), timer1_(io, boost::posix_time::seconds(1)), timer2_(io,
+		        boost::posix_time::seconds(1)), count_(0)
+	{
+		timer1_.async_wait(strand_.wrap(boost::bind(&printer::print1, this)));
+		timer2_.async_wait(strand_.wrap(boost::bind(&printer::print2, this)));
+	}
+
+	~printer()
+	{
+		std::cout << "Final count is " << count_ << "\n";
+	}
+
+	void print1()
+	{
+		if(count_ < 10)
+		{
+			std::cout << "Timer 1: " << count_ << "\n";
+			++count_;
+
+			timer1_.expires_at(timer1_.expires_at() + boost::posix_time::seconds(1));
+			timer1_.async_wait(strand_.wrap(boost::bind(&printer::print1, this)));
+		}
+	}
+
+	void print2()
+	{
+		if(count_ < 10)
+		{
+			std::cout << "Timer 2: " << count_ << "\n";
+			++count_;
+
+			timer2_.expires_at(timer2_.expires_at() + boost::posix_time::seconds(1));
+			timer2_.async_wait(strand_.wrap(boost::bind(&printer::print2, this)));
+		}
+	}
+
+private:
+	boost::asio::strand strand_;
+	boost::asio::deadline_timer timer1_;
+	boost::asio::deadline_timer timer2_;
+	int count_;
+};
+
+int main()
+{
+	boost::asio::io_service io;
+	printer p(io);
+	boost::thread t(boost::bind(&boost::asio::io_service::run, &io));
+	io.run();
+	t.join();
+
+	return 0;
+}

src/thread/thread_pool.cc

@@ -26,44 +26,44 @@ namespace hainan
 
 	void ThreadPool::Stop()
 	{
-		VLOG(2) << "Stop";
+		VLOG(3) << "Stop";
 		mutex::scoped_lock lock(mtx);
 		running = false;
 		cond.notify_all();
 		while(work_num > 0)
 		{
-			VLOG(2) << "done tasks size = " << tasks.size();
+			VLOG(3) << "done tasks size = " << tasks.size();
 			done.wait(lock);
 		}
 	}
 
 	void ThreadPool::Runner()
 	{
-		VLOG(2) << "thread start";
+		VLOG(3) << "thread start";
 		bool continued = true;
 		while(continued)
 		{
 			function<void (void)> task;
 			{
-				VLOG(2) << "loop lock";
+				VLOG(3) << "loop lock";
 				mutex::scoped_lock lock(mtx);
-				VLOG(2) << "loop lock ok";
+				VLOG(3) << "loop lock ok";
 				while(running && tasks.empty())
 				{
 					cond.wait(lock);
-					VLOG(2) << "cond";
+					VLOG(3) << "cond";
 				}
 				if(!tasks.empty())
 				{
-					VLOG(2) << "fetch task";
+					VLOG(3) << "fetch task";
 					task = tasks.front();
 					tasks.pop_front();
 				}
 				continued = running || !tasks.empty();
-				VLOG(2) << "continued = " << continued
+				VLOG(3) << "continued = " << continued
 						<< "running = " << running
 						<< " tasks size = " << tasks.size();
-				VLOG(2) << "loop unlock";
+				VLOG(3) << "loop unlock";
 			}
 
 			if(task)
@@ -73,14 +73,14 @@ namespace hainan
 		}
 		if(__sync_sub_and_fetch(&work_num, 1) == 0)
 		{
-			VLOG(2) << "work_num = " << work_num;
+			VLOG(3) << "work_num = " << work_num;
 			done.notify_one();
 		}
 	}
 
 	bool ThreadPool::PushTask(function<void (void)> task)
 	{
-		VLOG(2) << "push task";
+		VLOG(3) << "push task";
 		{
 			mutex::scoped_lock lock(mtx);
 			if(!running)
@@ -89,7 +89,7 @@ namespace hainan
 			}
 			tasks.push_back(task);
 		}
-		VLOG(2) << "push task unlock";
+		VLOG(3) << "push task unlock";
 		cond.notify_one();
 		return true;
 	}