src/plat-wxwidgets/thread.cpp

   1 #include "core/window.hpp"
   2
   3 #include <wx/thread.h>
   4
   5 struct wxw_mutex : public mutex
   6 {
   7         wxw_mutex() throw(std::bad_alloc);
   8         ~wxw_mutex() throw();
   9         void lock() throw();
  10         void unlock() throw();
  11         wxMutex* m;
  12 };
  13
  14 wxw_mutex::wxw_mutex() throw(std::bad_alloc)
  15 {
  16         m = new wxMutex();
  17 }
  18
  19 wxw_mutex::~wxw_mutex() throw()
  20 {
  21         delete m;
  22 }
  23
  24 void wxw_mutex::lock() throw()
  25 {
  26         m->Lock();
  27 }
  28
  29 void wxw_mutex::unlock() throw()
  30 {
  31         m->Unlock();
  32 }
  33
  34 mutex& mutex::aquire() throw(std::bad_alloc)
  35 {
  36         return *new wxw_mutex;
  37 }
  38
  39 struct wxw_condition : public condition
  40 {
  41         wxw_condition(mutex& m) throw(std::bad_alloc);
  42         ~wxw_condition() throw();
  43         bool wait(uint64_t x) throw();
  44         void signal() throw();
  45         wxCondition* c;
  46 };
  47
  48 wxw_condition::wxw_condition(mutex& m) throw(std::bad_alloc)
  49         : condition(m)
  50 {
  51         wxw_mutex* m2 = dynamic_cast<wxw_mutex*>(&m);
  52         c = new wxCondition(*m2->m);
  53 }
  54
  55 wxw_condition::~wxw_condition() throw()
  56 {
  57         delete c;
  58 }
  59
  60 bool wxw_condition::wait(uint64_t x) throw()
  61 {
  62         wxCondError e = c->WaitTimeout((x + 999) / 1000);
  63         return (e == wxCOND_NO_ERROR);
  64 }
  65
  66 void wxw_condition::signal() throw()
  67 {
  68         c->Broadcast();
  69 }
  70
  71 condition& condition::aquire(mutex& m) throw(std::bad_alloc)
  72 {
  73         return *new wxw_condition(m);
  74 }
  75
  76 struct wxw_thread_id : public thread_id
  77 {
  78         wxw_thread_id() throw();
  79         ~wxw_thread_id() throw();
  80         bool is_me() throw();
  81         uint32_t id;
  82 };
  83
  84 wxw_thread_id::wxw_thread_id() throw()
  85 {
  86         id = wxThread::GetCurrentId();
  87 }
  88
  89 wxw_thread_id::~wxw_thread_id() throw()
  90 {
  91 }
  92
  93 bool wxw_thread_id::is_me() throw()
  94 {
  95         return (id == wxThread::GetCurrentId());
  96 }
  97
  98 thread_id& thread_id::me() throw(std::bad_alloc)
  99 {
 100         return *new wxw_thread_id;
 101 }
 102
 103 struct wxw_thread;
 104
 105 struct wxw_thread_inner : public wxThread
 106 {
 107         wxw_thread_inner(wxw_thread* _up);
 108         void* (*entry)(void* arg);
 109         void* entry_arg;
 110         wxThread::ExitCode Entry();
 111         wxw_thread* up;
 112 };
 113
 114 struct wxw_thread : public thread
 115 {
 116         wxw_thread(void* (*fn)(void* arg), void* arg) throw(std::bad_alloc, std::runtime_error);
 117         ~wxw_thread() throw();
 118         void _join() throw();
 119         bool has_waited;
 120         wxw_thread_inner* inner;
 121         void notify_quit2(void* ret);
 122 };
 123
 124 wxw_thread_inner::wxw_thread_inner(wxw_thread* _up)
 125         : wxThread(wxTHREAD_JOINABLE)
 126 {
 127         up = _up;
 128 }
 129
 130 void wxw_thread::notify_quit2(void* ret)
 131 {
 132         notify_quit(ret);
 133 }
 134
 135 wxThread::ExitCode wxw_thread_inner::Entry()
 136 {
 137         up->notify_quit2(entry(entry_arg));
 138         return 0;
 139 }
 140
 141 wxw_thread::wxw_thread(void* (*fn)(void* arg), void* arg) throw(std::bad_alloc, std::runtime_error)
 142 {
 143         has_waited = false;
 144         inner = new wxw_thread_inner(this);
 145         inner->entry = fn;
 146         inner->entry_arg = arg;
 147         wxThreadError e = inner->Create(8 * 1024 * 1024);
 148         if(e != wxTHREAD_NO_ERROR)
 149                 throw std::bad_alloc();
 150         e = inner->Run();
 151         if(e != wxTHREAD_NO_ERROR)
 152                 throw std::bad_alloc();
 153 }
 154
 155 wxw_thread::~wxw_thread() throw()
 156 {
 157         if(inner) {
 158                 inner->Wait();
 159                 inner = NULL;
 160         }
 161 }
 162
 163 void wxw_thread::_join() throw()
 164 {
 165         if(inner) {
 166                 inner->Wait();
 167                 inner = NULL;
 168         }
 169 }
 170
 171 thread& thread::create(void* (*entrypoint)(void* arg), void* arg) throw(std::bad_alloc, std::runtime_error)
 172 {
 173         return *new wxw_thread(entrypoint, arg);
 174 }