root/trunk/dep/src/zthread/macos/ThreadOps.cxx

Revision 2, 2.3 kB (checked in by yumileroy, 17 years ago)

[svn] * Proper SVN structure

Original author: Neo2003
Date: 2008-10-02 16:23:55-05:00
Line 
1/*
2 * Copyright (c) 2005, Eric Crahen
3 *
4 * Permission is hereby granted, free of charge, to any person obtaining a copy
5 * of this software and associated documentation files (the "Software"), to deal
6 * in the Software without restriction, including without limitation the rights
7 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
8 * copies of the Software, and to permit persons to whom the Software is furnished
9 * to do so, subject to the following conditions:
10 *
11 * The above copyright notice and this permission notice shall be included in all
12 * copies or substantial portions of the Software.
13 *
14 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
15 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
16 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
17 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY,
18 * WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
19 * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
20 *
21 */
22
23
24#include "ThreadOps.h"
25#include "zthread/Exceptions.h"
26#include "zthread/Runnable.h"
27
28namespace ZThread {
29
30const ThreadOps ThreadOps::INVALID(0);
31
32ThreadOps::ThreadOps()  : _queue(0), _tid(0) {
33 
34  if(MPCreateQueue(&_queue) != noErr)
35    throw Initialization_Exception();
36
37}
38
39ThreadOps::~ThreadOps() throw() {
40 
41  if(_queue != 0) {
42
43    OSStatus status = MPDeleteQueue(_queue);
44    if(status != noErr)
45      assert(0);
46
47  }
48   
49}
50
51bool ThreadOps::join(ThreadOps* ops) {
52
53  assert(ops);
54  assert(ops->_tid != 0);
55
56  OSStatus status = MPWaitOnQueue(ops->_queue, NULL, NULL, NULL, kDurationForever);
57
58  return status == noErr;
59 
60}
61
62bool ThreadOps::yield() {
63
64  MPYield();
65  return true;
66
67}
68
69bool ThreadOps::setPriority(ThreadOps* impl, Priority p) {
70  return true;
71}
72
73bool ThreadOps::getPriority(ThreadOps* impl, Priority& p) {
74  return true;
75}
76
77
78bool ThreadOps::spawn(Runnable* task) {
79
80  OSStatus status =
81    MPCreateTask(&_dispatch, task, 0UL, _queue, NULL, NULL, 0UL, &_tid);
82
83  return status == noErr;
84
85}
86
87OSStatus ThreadOps::_dispatch(void *arg) {
88
89  Runnable* task = reinterpret_cast<Runnable*>(arg);
90  assert(task);
91
92  // Run the task from the correct context
93  task->run();
94 
95  // Exit the thread
96  MPExit(noErr);
97  return noErr;
98
99}
100 
101} // namespace ZThread
102
103
Note: See TracBrowser for help on using the browser.