| // thread -*- C++ -*- |
| |
| // Copyright (C) 2008, 2009 Free Software Foundation, Inc. |
| // |
| // This file is part of the GNU ISO C++ Library. This library is free |
| // software; you can redistribute it and/or modify it under the |
| // terms of the GNU General Public License as published by the |
| // Free Software Foundation; either version 3, or (at your option) |
| // any later version. |
| |
| // This library is distributed in the hope that it will be useful, |
| // but WITHOUT ANY WARRANTY; without even the implied warranty of |
| // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
| // GNU General Public License for more details. |
| |
| // Under Section 7 of GPL version 3, you are granted additional |
| // permissions described in the GCC Runtime Library Exception, version |
| // 3.1, as published by the Free Software Foundation. |
| |
| // You should have received a copy of the GNU General Public License and |
| // a copy of the GCC Runtime Library Exception along with this program; |
| // see the files COPYING3 and COPYING.RUNTIME respectively. If not, see |
| // <http://www.gnu.org/licenses/>. |
| |
| |
| #include <thread> |
| #include <cerrno> |
| |
| #if defined(_GLIBCXX_HAS_GTHREADS) && defined(_GLIBCXX_USE_C99_STDINT_TR1) |
| |
| namespace std |
| { |
| namespace |
| { |
| extern "C" void* |
| execute_native_thread_routine(void* __p) |
| { |
| thread::_Impl_base* __t = static_cast<thread::_Impl_base*>(__p); |
| thread::__shared_base_type __local; |
| __local.swap(__t->_M_this_ptr); |
| |
| __try |
| { |
| __t->_M_run(); |
| } |
| __catch(...) |
| { |
| std::terminate(); |
| } |
| |
| return 0; |
| } |
| } |
| |
| void |
| thread::join() |
| { |
| int __e = EINVAL; |
| |
| if (_M_id != id()) |
| __e = __gthread_join(_M_id._M_thread, NULL); |
| |
| if (__e) |
| __throw_system_error(__e); |
| |
| _M_id = id(); |
| } |
| |
| void |
| thread::detach() |
| { |
| int __e = EINVAL; |
| |
| if (_M_id != id()) |
| __e = __gthread_detach(_M_id._M_thread); |
| |
| if (__e) |
| __throw_system_error(__e); |
| |
| _M_id = id(); |
| } |
| |
| void |
| thread::_M_start_thread(__shared_base_type __b) |
| { |
| __b->_M_this_ptr = __b; |
| int __e = __gthread_create(&_M_id._M_thread, |
| &execute_native_thread_routine, __b.get()); |
| if (__e) |
| { |
| __b->_M_this_ptr.reset(); |
| __throw_system_error(__e); |
| } |
| } |
| } |
| |
| #endif // _GLIBCXX_HAS_GTHREADS && _GLIBCXX_USE_C99_STDINT_TR1 |