I would like to test my class which implements shared data. because of it I have written test code which use boost::thread & boost asio (please see below). the problem is that threads are NOT started... on multicore machine. one one core machine it runs fine. any idea why? tom #include <iostream> #include <istream> #include <ostream> #include <string> #include <boost/asio.hpp> #include <boost/date_time/posix_time/posix_time.hpp> #include <boost/bind.hpp> #include <boost/thread.hpp> #include "shared.hpp" #include <boost/random/linear_congruential.hpp> #include <boost/random/uniform_real.hpp> #include <boost/random/variate_generator.hpp> SharedData replyToClients; void handle_timeout1(const boost::system::error_code&) { boost::minstd_rand generator(42u); boost::uniform_real<> uni_dist(0,1); boost::variate_generator<boost::minstd_rand, boost::uniform_real<>
uni(generator, uni_dist);
std::string key = "ello";std::cout<<key<<std::endl; std::string value1 = "see you later aligator"; std::string value2 = "what do you want to eat today?"; double cond = 0.500000; while(true){ if(uni() >= cond){ replyToClients.set(key,value1); }else{ replyToClients.set(key,value2); } } } void handle_timeout2(const boost::system::error_code&) { std::string key = "ello"; while(true){ std::cout<<replyToClients.get(key); } } int main(int argc, char* argv[]) { try{ boost::asio::io_service io_service; boost::system::error_code error; //boost::asio::io_service::work work(io_service); io_service.post(boost::bind(handle_timeout1,error)); io_service.post(boost::bind(handle_timeout2,error)); io_service.post(boost::bind(handle_timeout2,error)); io_service.post(boost::bind(handle_timeout2,error)); boost::thread thread1(boost::bind(&boost::asio::io_service::run, &io_service)); boost::thread thread2(boost::bind(&boost::asio::io_service::run, &io_service)); boost::thread thread3(boost::bind(&boost::asio::io_service::run, &io_service)); boost::thread thread4(boost::bind(&boost::asio::io_service::run, &io_service)); //io_service.run(); std::cout<<"the end\n"; io_service.stop(); thread1.join(); thread2.join(); thread3.join(); thread4.join(); } catch (boost::system::system_error& er) {std::cout << "Exception er: " << er.what() << "\n"; } catch (std::exception& e) { std::cout << "Exception e: " << e.what() << "\n"; } return 0; } ---------------------------------------------------- Nużą Cię utarte scenariusze? Wymyśl własną grę flashową i wygraj główną nagrodę 5.500 Euro: http://klik.wp.pl/?adr=http%3A%2F%2Fwhosegame.pl%2Fcontestcard.php%3Fcontest%3D55&sid=631