Create Main.cpp

Author: lzpong

Main.cpp

@@ -0,0 +1,91 @@
+#include "threadpool.h"
+#include <iostream>
+#include <windows.h>
+
+
+void fun1(int slp)
+{
+	printf("  hello, fun1 !  %d\n" ,std::this_thread::get_id());
+	if (slp>0) {
+		printf(" ======= fun1 sleep %d  =========  %d\n",slp, std::this_thread::get_id());
+		std::this_thread::sleep_for(std::chrono::milliseconds(slp));
+		//Sleep(slp );
+	}
+}
+
+struct gfun {
+	int operator()(int n) {
+		printf("%d  hello, gfun !  %d\n" ,n, std::this_thread::get_id() );
+		return 42;
+	}
+};
+
+class A {    //函数必须是 static 的才能使用线程池
+public:
+	static int Afun(int n = 0) {
+		std::cout << n << "  hello, Afun !  " << std::this_thread::get_id() << std::endl;
+		return n;
+	}
+
+	static std::string Bfun(int n, std::string str, char c) {
+		std::cout << n << "  hello, Bfun !  "<< str.c_str() <<"  " << (int)c <<"  " << std::this_thread::get_id() << std::endl;
+		return str;
+	}
+};
+
+int main()
+	try {
+		std::threadpool executor{ 50 };
+		A a;
+		std::future<void> ff = executor.commit(fun1,0);
+		std::future<int> fg = executor.commit(gfun{},0);
+		std::future<int> gg = executor.commit(a.Afun, 9999); //IDE提示错误,但可以编译运行
+		std::future<std::string> gh = executor.commit(A::Bfun, 9998,"mult args", 123);
+		std::future<std::string> fh = executor.commit([]()->std::string { std::cout << "hello, fh !  " << std::this_thread::get_id() << std::endl; return "hello,fh ret !"; });
+
+		std::cout << " =======  sleep ========= " << std::this_thread::get_id() << std::endl;
+		std::this_thread::sleep_for(std::chrono::microseconds(900));
+
+		for (int i = 0; i < 50; i++) {
+			executor.commit(fun1,i*100 );
+		}
+		std::cout << " =======  commit all ========= " << std::this_thread::get_id()<< " idlsize="<<executor.idlCount() << std::endl;
+
+		std::cout << " =======  sleep ========= " << std::this_thread::get_id() << std::endl;
+		std::this_thread::sleep_for(std::chrono::seconds(3));
+
+		ff.get(); //调用.get()获取返回值会等待线程执行完,获取返回值
+		std::cout << fg.get() << "  " << fh.get().c_str()<< "  " << std::this_thread::get_id() << std::endl;
+
+		std::cout << " =======  sleep ========= " << std::this_thread::get_id() << std::endl;
+		std::this_thread::sleep_for(std::chrono::seconds(3));
+
+		std::cout << " =======  fun1,55 ========= " << std::this_thread::get_id() << std::endl;
+		executor.commit(fun1,55).get();    //调用.get()获取返回值会等待线程执行完
+
+		std::cout << "end... " << std::this_thread::get_id() << std::endl;
+
+
+		std::threadpool pool(4);
+		std::vector< std::future<int> > results;
+
+		for (int i = 0; i < 8; ++i) {
+			results.emplace_back(
+				pool.commit([i] {
+					std::cout << "hello " << i << std::endl;
+					std::this_thread::sleep_for(std::chrono::seconds(1));
+					std::cout << "world " << i << std::endl;
+					return i*i;
+				})
+			);
+		}
+		std::cout << " =======  commit all2 ========= " << std::this_thread::get_id() << std::endl;
+
+		for (auto && result : results)
+			std::cout << result.get() << ' ';
+		std::cout << std::endl;
+		return 0;
+	}
+catch (std::exception& e) {
+	std::cout << "some unhappy happened...  " << std::this_thread::get_id() << e.what() << std::endl;
+}