- Boost-users - lists.boost.org

Re: [Boost-users] [boost::thread] interrupt a future get boost::unknown_exception
by 乔志强 21 Mar '11

21 Mar '11

It is only boost::thread int foo() { this_thread::sleep(seconds(1000)); return 0; } int main(int argc, char** argv) { boost::packaged_task<int> pt(&foo); boost::unique_future<int> fi = pt.get_future(); .......................... > > ------------------------------ > > Message: 2 > Date: Fri, 18 Mar 2011 16:43:54 +0100 > From: Viatcheslav.Sysoltsev(a)h-d-gmbh.de > To: boost-users(a)lists.boost.org > Subject: Re: [Boost-users] [boost::thread] interrupt a future get > boost::unknown_exception > Message-ID: <op.vsjpzgww5q4lf0@pc-sysolts-zdmf> > Content-Type: text/plain; charset=utf-8; format=flowed; delsp=yes > > On Fri, 18 Mar 2011 11:30:11 +0100, ??? <qiaozhiqiang(a)leadcoretech.com> > wrote: > > > [Windows XP, VC++ 10, boost 1.46] > > When interrupt a future, the future.get() throw boost::unknown_exception, > > Not boost::thread_interrupted. > > > > Class boost::thread_interrupted should have a base class for > > current_exception_impl() to catch it ? or use BOOST_THROW_EXCEPTION in > > interruptible_wait) ? > > > > > > /////////////// > > namespace boost > > { > > class thread_interrupted > > {}; > > } > > > > > > exception_ptr current_exception_impl() > > { > > try > > { > > throw; > > } > > catch( > > exception_detail::clone_base & e ) > > { > > return exception_ptr(e.clone()); > > } > > ................ > > catch( > > std::exception & e ) > > { > > return > > exception_detail::current_exception_unknown_std_exception(e); > > } > > catch( > > boost::exception & e ) > > { > > return > > exception_detail::current_exception_unknown_boost_exception(e); > > } > > catch( > > ... ) > > { > > return > > exception_detail::current_exception_unknown_exception(); > > } > > > > > > // unknown_exception////////////////// > > ERROR: Throw in function (unknown) > > Dynamic exception type: class boost::exception_detail::clone_impl<class > > boost::unknown_exception> > > std::exception::what: Unknown exception > > > > > > > > //code ///////////////////// > > #include <boost/thread.hpp> > > #include <boost/date_time/posix_time/posix_time_types.hpp> > > #include <boost/thread/future.hpp> > > using namespace boost::posix_time; > > using namespace boost; > > > > int main(int argc, char** argv) > > { > > boost::packaged_task<int> pt( > > [=]()->int > > { > > this_thread::sleep(seconds(1000)); > > return 0; > > } > > ); > > boost::unique_future<int> fi = pt.get_future(); > > boost::thread task(std::move(pt)); // launch task on a thread > > > > task.interrupt(); > > > > try > > { > > int v = fi.get(); > > } > > catch (boost::exception& exc) > > { > > std::cerr << "ERROR: " << boost::diagnostic_information(exc) << > > std::endl; > > } > > } > > Wow, boost-1.46 and lambdas, you're really working on the edge. Just to be > sure it is a boost problem - can you make a classical function instead > lambda and try with it? The test case seems nearly like one from the > futures example - I really doubt it is a boost problem. > I'd be glad to experiment with it yourself but my latest ubuntu has only > gcc 4.4.5 and the lambdas said to be supported first from 4.5, plus I'd > need to build 1.46 first, which takes quite a time on my nearly-netbook.. > > -- Slava > >

2 2

mpl and set of maps
by Peter Foelsche 21 Mar '11

21 Mar '11

It looks like two maps with the same entries but different ordering are considered different. I'm trying to create a set of maps and I'm inserting two maps. Both maps are identical but the order in which the items were inserted into the map is different. I was thinking that an associative sequence like set is using is_same to compare two elements and I tried to overload is_same -- but this did not work. See code below or attached. #include <boost/mpl/set.hpp> #include <boost/mpl/map.hpp> #include <boost/mpl/bool.hpp> #include <boost/mpl/long.hpp> #include <boost/mpl/for_each.hpp> #include <boost/mpl/insert.hpp> #include <iostream> ? struct print { template<typename T> void operator()(const T &_r) const { //std::cout << typeid(T).name() << "\n"; (*this)(_r, typename boost::mpl::is_sequence<T>::type()); } template<typename T> void operator()(const T &, const boost::mpl::true_ &) const { std::cout << "(\n"; boost::mpl::for_each<T>(print()); std::cout << ")\n"; } template<typename T0, typename T1> void operator()(const boost::mpl::pair<T0, T1> &, const boost::mpl::false_ &) const { std::cout << "pair(" << typeid(T0).name() << ", " << typeid(T1).name() << ")" << "\n"; } template<typename T> void operator()(const T &, const boost::mpl::false_ &) const { std::cout << typeid(T).name() << "\n"; } }; namespace boost { //namespace type_traits //{ //template<typename T0, typename T1> //struct is_same; ? using boost::mpl::map; using boost::mpl::true_; using boost::mpl::insert; ? template<typename T0, typename T1> struct is_same<map<T0, T1>, map<T1, T0> > { typedef boost::mpl::true_ type; }; ? template<typename T0, typename T1, typename T2> struct is_same<map<T0, T1, T2>, map<T2, T1, T0> > { typedef boost::mpl::true_ type; }; ? template<typename T0, typename T1, typename T2> struct is_same<map<T0, T1, T2>, map<T1, T2, T0> > { typedef boost::mpl::true_ type; }; ? template<typename T0, typename T1, typename T2> struct is_same<map<T0, T1, T2>, map<T0, T2, T1> > { typedef boost::mpl::true_ type; }; ? template<typename T0, typename T1, typename T2> struct is_same<map<T0, T1, T2>, map<T1, T0, T2> > { typedef boost::mpl::true_ type; }; //} } int main(int argc, char **argv) { using boost::mpl::long_; using boost::mpl::for_each; using boost::mpl::set; using boost::mpl::map; using boost::mpl::pair; using boost::mpl::insert; typedef long_<0> zero; typedef long_<1> one; typedef long_<2> two; typedef pair< zero, one > zero_2_one; typedef pair< one, one > one_2_one; for_each< insert< insert< set<>, insert< insert< map<>, zero_2_one >::type, one_2_one >::type >::type, insert< insert< map<>, one_2_one >::type, zero_2_one >::type >::type >(print()); return 0; }

3 3

issue with make_shared
by Sean Farrow 21 Mar '11

21 Mar '11

Hi: Ok, having got to grips with fusion, and thought it was working. I now have an issue whereby when using make_shared, it is working in one case, and not in the other. I've got the following definition:P typedef boost::fusion::vector<PmStream*, MIDIInputThread, boost::shared_ptr<boost::asio::io_service> , boost::shared_ptr<boost::thread> > InputType; and when I use: InputType NewInput =InputType(Port, cl, boost::make_shared<boost::asio::io_service> , boost::make_shared<boost::thread>(boost::bind(&boost::asio::io_service::run, io.get()))); Replacing the asio::io declaration with an actual variable of type boost::shared_ptr<boost::asio::io_service> seems to work fine. Is ther anything I'm doing wrong that's not allowing me to use boost::make_shared? Any help appreciated. Regards Sean.

3 2

refering to objects when constructing a boost::fusion::vector
by Sean Farrow 21 Mar '11

21 Mar '11

Hi list: I'm in the process of using boost::fusion::vector, with the following definition: typedef boost::fusion::vector<PmStream*, MIDIInputThread, boost::shared_ptr<boost::asio::io_service>, boost::shared_ptr<boost::thread> > InputType; I'm then constructing this using the following code: PmStream* Port; MIDIInputThread cl; InputType NewInput =InputType(Port, cl, boost::make_shared<boost::asio::io_service>, boost::make_shared<boost::thread>(boost::bind(&boost::asio::io_service::run, io.get()))); What I'm wondering is is there a way to refer to a previously declared argument in this case, I'd like to refer to the shared pointer containing the boost::asio::io_service. Given that I've not actually named this argument, could I use anything from either boost.fusion or boost.mpl to do what I require. Any help appreciated. Regards Sean.

3 2

storing a boost.thread in a boost shared ptr
by Sean Farrow 21 Mar '11

21 Mar '11

Hi: I'm trying to store a boost.thread in a boost::fusion::vector, and need to use a shared ptr, due to boost.thrad being non-copyable I'm using Microsoft visual c++ 2010. I get the following error: 1>d:\devexpress\mdrlite\mdrlite\mdrlite\midiwidget.cpp(21): error C2664: 'boost::shared_ptr<T>::shared_ptr(boost::shared_ptr<T> &&)' : cannot convert parameter 1 from 'boost::_bi::bind_t<R,F,L>' to 'boost::shared_ptr<T> &&' with [ T=boost::thread ] and [ R=size_t, F=boost::_mfi::mf0<size_t,boost::asio::io_service>, L=boost::_bi::list1<boost::_bi::value<boost::asio::io_service *>> ] and [ T=boost::thread ] Reason: cannot convert from 'boost::_bi::bind_t<R,F,L>' to 'boost::shared_ptr<T>' with [ R=size_t, F=boost::_mfi::mf0<size_t,boost::asio::io_service>, L=boost::_bi::list1<boost::_bi::value<boost::asio::io_service *>> ] and [ T=boost::thread ] No user-defined-conversion operator available that can perform this conversion, or the operator cannot be called My boost thread is defined as: boost::thread t(boost::bind(&boost::asio::io_service::run, io.get())); and io is defined as: boost::shared_ptr<boost::asio::io_service> io; I'm obviously overlooking something, I just carn't work out what? Any help appreciated. Regards Sean.

4 5

[context review] Review starts today, Mars 21st 2011
by Vicente BOTET 21 Mar '11

21 Mar '11

Hi all, The review of Oliver Kowalke Context library starts today Mars 21st 2011, and will end on Mars 30th. Boost.Context is a basic building block library that is used for more higher abstractions. It is used by Boost.Fiber, Boost.Tasklet and Boost.Task from the same author. I really hope to see your vote and your participation in the discussions on the Boost DEVELOPMENT mailing lists! WARNING !!!!!!!!!!!!! Only on the Boost DEVELOPMENT mailing lists Please use [context review] as prefix of your post to make easier the review follow up. You can download a frozen version for the review from the Vault, TinyURL: http://tinyurl.com/5r77rel or The documentation is available directly here: http://ok73.ok.funpic.de/boost/libs/context/doc/html/ --------------------------------------------------- About the library: Boost.Context provides a possibility to switch between different user-level context and is intended to be the basis for a higher abstraction like coroutine and fiber. A user-level context represents the current execution state, including all registers and CPU flags, the instruction pointer, the stack pointer. boost::context encapsulates such a user-level context and is able to store/restore its associated user-level context. This allows multiple execution paths running on a single thread using a sort of cooperative scheduling (in contrast a thread is preemptively scheduled) - the running boost::context decides explicitly when its yields to allow another boost::context to run (user-level context switching). A context can only run on a single thread at any point in time but may be migrated between thread. A context switch between threads costs usually thousands of CPU cycles on x86 compared to a user-level context switch with few hundreds of cycles. Boost.Context differes to setjmp()/longjmp() in the fact that the C99 standard does not require that longjmp() preserves the current stack frame, e. g. jumping into a function which was exited via a call to longjmp() is undefined. Boost.Context allows to select the mechanism provided by the operating system (ucontext on UNIX, Windows Fibers on Windows) or a faster implementation provided by this library (fcontext using assembler). --------------------------------------------------- Please always state in your review, whether you think the library should be accepted as a Boost library! Additionally please consider giving feedback on the following general topics: - What is your evaluation of the design? - What is your evaluation of the implementation? - What is your evaluation of the documentation? - What is your evaluation of the potential usefulness of the library? - Did you try to use the library? With what compiler? Did you have any problems? - How much effort did you put into your evaluation? A glance? A quick reading? In-depth study? - Are you knowledgeable about the problem domain? Have a good review, Vicente Review Manager

5 5

[Fusion] value_at_c and its relatives not applicable to Associative Sequence?
by TONGARI 21 Mar '11

21 Mar '11

Hi, the document says that 'value_at_c' accepts a Forward Sequence, and set/map, which is of Associative Sequence as well as Forward Sequence, why the following does not work? #include <boost/fusion/include/value_at.hpp> #include <boost/fusion/include/set.hpp> int main() { namespace fs = boost::fusion; typedef fs::result_of::value_at_c<fs::set<int>, 0> >::type type; return 0; }

3 5

Re: [Boost-users] using boost.asio with wx widgets
by Marat Abrarov 21 Mar '11

21 Mar '11

Hi, Sean Farrow. I use Boost.Asio with Qt. I don't use the default MSVS C++ project structure with additional header, where MSVS adds some preprocessor directives by default. So I moved those directives (preprocessor defines) to project settings: WIN32 WIN32_LEAN_AND_MEAN WINVER=0x0500 _WIN32_WINNT=0x0500 _WIN32_WINDOWS=0x0410 _WIN32_IE=0x0600 May be would solve your problem? Regards, Marat Abrarov.

1 0

Thread Interruption Best Practice
by Dom Driver 21 Mar '11

21 Mar '11

Hi List, I'm fairly new to boost, and have recently started to use the threading system from v1.46 in an app I'm writing targeting Linux. This was primarily to enable execution of threads to be blocked until a condition variable is set, at which point the thread is kicked awake and actions whatever is waiting to be done. All good, and all working as expected. However, I've got another thread which sits listening for data on a socket using a Linux select() call. This blocks until data is available for reading, at which point it is read from the socket as expected. This also works fine, except on termination of the application. Using native Linux implementations, a signal can be sent to the thread that is blocking on the select() call, at which point the call returns, and the EINTR error is set. I can therefore check for this condition and handle appropriately. Is there a way to send a Linux signal (or boost equivalent) to a specific boost thread to emulate this behaviour? Failing that, is there an alternative implementation of the classic Linux select()/read() functionality using boost classes? I had a look at the async I/O library and it seems a bit convoluted. TIA, Dom

3 2

Re: [Boost-users] [boost::thread] interrupt a future get boost::unknown_exception
by 乔志强 21 Mar '11

21 Mar '11

It may be a bug of the thread or future. in boost_1_46_0/doc/html/thread/synchronization.html these Member functions: shared_future class template: Member function get() Member function wait() Member function timed_wait() and unique_future class template: Member function get() Member function wait() Member function timed_wait() Throws: ........ boost::thread_interrupted if the result associated with *this is not ready at the point of the call, and the [current] thread is interrupted. ............ the [current] thread is interrupted. Should be the [working] thread is interrupted ? > > [Windows XP, VC++ 10, boost 1.46] > > When interrupt a future, the future.get() throw boost::unknown_exception, > > Not boost::thread_interrupted. > > > > Class boost::thread_interrupted should have a base class for > > current_exception_impl() to catch it ? or use BOOST_THROW_EXCEPTION to throw ? ////////// namespace boost { class thread_interrupted {}; } These function use [ throw thread_interrupted(); ] : this_thread ::interruption_point() // pthread / win32 this_thread::interruptible_wait() // win32 interruption_checker:: check_for_interruption()// pthread ///////////// // [Windows XP, VC++ 10, boost 1.46] #include <boost/thread.hpp> #include <boost/date_time/posix_time/posix_time_types.hpp> #include <boost/thread/future.hpp> using namespace boost::posix_time; using namespace boost; int foo() { this_thread::sleep(seconds(1000)); return 0; } int main(int argc, char** argv) { boost::packaged_task<int> pt(&foo); boost::unique_future<int> fi = pt.get_future(); boost::thread task(std::move(pt)); // launch task on a thread task.interrupt(); try { int v = fi.get(); } catch (boost::exception& exc) { std::cerr << "ERROR: " << boost::diagnostic_information(exc) << std::endl; } } > > > > // unknown_exception////////////////// > > ERROR: Throw in function (unknown) > > Dynamic exception type: class boost::exception_detail::clone_impl<class > > boost::unknown_exception> > > std::exception::what: Unknown exception

1 0