libstdc++-v3/src/thread.cc

   1 // thread -*- C++ -*-
   2
   3 // Copyright (C) 2008, 2009, 2010, 2011 Free Software Foundation, Inc.
   4 //
   5 // This file is part of the GNU ISO C++ Library.  This library is free
   6 // software; you can redistribute it and/or modify it under the
   7 // terms of the GNU General Public License as published by the
   8 // Free Software Foundation; either version 3, or (at your option)
   9 // any later version.
  10
  11 // This library is distributed in the hope that it will be useful,
  12 // but WITHOUT ANY WARRANTY; without even the implied warranty of
  13 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  14 // GNU General Public License for more details.
  15
  16 // Under Section 7 of GPL version 3, you are granted additional
  17 // permissions described in the GCC Runtime Library Exception, version
  18 // 3.1, as published by the Free Software Foundation.
  19
  20 // You should have received a copy of the GNU General Public License and
  21 // a copy of the GCC Runtime Library Exception along with this program;
  22 // see the files COPYING3 and COPYING.RUNTIME respectively.  If not, see
  23 // <http://www.gnu.org/licenses/>.
  24
  25
  26 #include <thread>
  27 #include <system_error>
  28 #include <cerrno>
  29
  30 #if defined(_GLIBCXX_USE_GET_NPROCS)
  31 # include <sys/sysinfo.h>
  32 # define _GLIBCXX_NPROCS get_nprocs()
  33 #elif defined(_GLIBCXX_USE_SC_NPROCESSORS_ONLN)
  34 # include <unistd.h>
  35 # define _GLIBCXX_NPROCS sysconf(_SC_NPROCESSORS_ONLN)
  36 #else
  37 # define _GLIBCXX_NPROCS 0
  38 #endif
  39
  40 #if defined(_GLIBCXX_HAS_GTHREADS) && defined(_GLIBCXX_USE_C99_STDINT_TR1)
  41
  42 namespace std _GLIBCXX_VISIBILITY(default)
  43 {
  44   namespace
  45   {
  46     extern "C" void*
  47     execute_native_thread_routine(void* __p)
  48     {
  49       thread::_Impl_base* __t = static_cast<thread::_Impl_base*>(__p);
  50       thread::__shared_base_type __local;
  51       __local.swap(__t->_M_this_ptr);
  52
  53       __try
  54         {
  55           __t->_M_run();
  56         }
  57       __catch(...)
  58         {
  59           std::terminate();
  60         }
  61
  62       return 0;
  63     }
  64   }
  65
  66 _GLIBCXX_BEGIN_NAMESPACE_VERSION
  67
  68   void
  69   thread::join()
  70   {
  71     int __e = EINVAL;
  72
  73     if (_M_id != id())
  74       __e = __gthread_join(_M_id._M_thread, 0);
  75
  76     if (__e)
  77       __throw_system_error(__e);
  78
  79     _M_id = id();
  80   }
  81
  82   void
  83   thread::detach()
  84   {
  85     int __e = EINVAL;
  86
  87     if (_M_id != id())
  88       __e = __gthread_detach(_M_id._M_thread);
  89
  90     if (__e)
  91       __throw_system_error(__e);
  92
  93     _M_id = id();
  94   }
  95
  96   void
  97   thread::_M_start_thread(__shared_base_type __b)
  98   {
  99     if (!__gthread_active_p())
 100       __throw_system_error(int(errc::operation_not_permitted));
 101
 102     __b->_M_this_ptr = __b;
 103     int __e = __gthread_create(&_M_id._M_thread,
 104                                &execute_native_thread_routine, __b.get());
 105     if (__e)
 106     {
 107       __b->_M_this_ptr.reset();
 108       __throw_system_error(__e);
 109     }
 110   }
 111
 112   unsigned int
 113   thread::hardware_concurrency() noexcept
 114   {
 115     int __n = _GLIBCXX_NPROCS;
 116     if (__n < 0)
 117       __n = 0;
 118     return __n;
 119   }
 120
 121 _GLIBCXX_END_NAMESPACE_VERSION
 122 } // namespace std
 123
 124 #endif // _GLIBCXX_HAS_GTHREADS && _GLIBCXX_USE_C99_STDINT_TR1