Differences From Artifact [44538b1550]:
- File
src/OFThread.m
— part of check-in
[44f45c2e35]
at
2017-01-09 17:36:36
on branch trunk
— Update copyright
Forgot to add 2017, even though I already did quite some changes in
2017. (user: js, size: 8966) [annotate] [blame] [check-ins using]
To Artifact [a839633991]:
- File
src/OFThread.m
— part of check-in
[4af49a13c3]
at
2017-05-07 20:10:13
on branch trunk
— Small code style change
Casts are now written like types in variable declarations. (user: js, size: 8975) [annotate] [blame] [check-ins using]
| ︙ | ︙ | |||
95 96 97 98 99 100 101 |
static of_tlskey_t threadSelfKey;
static OFThread *mainThread;
static void
callMain(id object)
{
| | | 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 |
static of_tlskey_t threadSelfKey;
static OFThread *mainThread;
static void
callMain(id object)
{
OFThread *thread = (OFThread *)object;
if (!of_tlskey_set(threadSelfKey, thread))
@throw [OFInitializationFailedException
exceptionWithClass: [thread class]];
thread->_pool = objc_autoreleasePoolPush();
|
| ︙ | ︙ | |||
153 154 155 156 157 158 159 |
# ifdef OF_HAVE_BLOCKS
+ (instancetype)threadWithThreadBlock: (of_thread_block_t)threadBlock
{
return [[[self alloc] initWithThreadBlock: threadBlock] autorelease];
}
# endif
| | | | | 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 |
# ifdef OF_HAVE_BLOCKS
+ (instancetype)threadWithThreadBlock: (of_thread_block_t)threadBlock
{
return [[[self alloc] initWithThreadBlock: threadBlock] autorelease];
}
# endif
+ (OFThread *)currentThread
{
return of_tlskey_get(threadSelfKey);
}
+ (OFThread *)mainThread
{
return mainThread;
}
+ (OFMutableDictionary *)threadDictionary
{
OFThread *thread = of_tlskey_get(threadSelfKey);
if (thread->_threadDictionary == nil)
thread->_threadDictionary = [[OFMutableDictionary alloc] init];
return thread->_threadDictionary;
|
| ︙ | ︙ | |||
218 219 220 221 222 223 224 | sleep((unsigned int)timeInterval); usleep((useconds_t)lrint( (timeInterval - floor(timeInterval)) * 1000000)); #endif } | | | 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 |
sleep((unsigned int)timeInterval);
usleep((useconds_t)lrint(
(timeInterval - floor(timeInterval)) * 1000000));
#endif
}
+ (void)sleepUntilDate: (OFDate *)date
{
[self sleepForTimeInterval: [date timeIntervalSinceNow]];
}
+ (void)yield
{
#ifdef OF_HAVE_SCHED_YIELD
|
| ︙ | ︙ | |||
365 366 367 368 369 370 371 |
}
- copy
{
return [self retain];
}
| | | | | | 365 366 367 368 369 370 371 372 373 374 375 376 377 378 379 380 381 382 383 384 385 386 387 388 389 390 391 392 393 394 395 396 397 398 399 400 401 402 403 |
}
- copy
{
return [self retain];
}
- (OFRunLoop *)runLoop
{
# ifdef OF_HAVE_ATOMIC_OPS
if (_runLoop == nil) {
OFRunLoop *tmp = [[OFRunLoop alloc] init];
if (!of_atomic_ptr_cmpswap((void **)&_runLoop, nil, tmp))
[tmp release];
}
# else
@synchronized (self) {
if (_runLoop == nil)
_runLoop = [[OFRunLoop alloc] init];
}
# endif
return [[_runLoop retain] autorelease];
}
- (OFString *)name
{
return [[_name copy] autorelease];
}
- (void)setName: (OFString *)name
{
OFString *old = name;
_name = [name copy];
[old release];
if (_running == OF_THREAD_RUNNING)
of_thread_set_name(_thread, (_name != nil
|
| ︙ | ︙ |