OOAsyncWorkManagerInternal Class Reference

Inheritance diagram for OOAsyncWorkManagerInternal:

Collaboration diagram for OOAsyncWorkManagerInternal:

Instance Methods
(void)	- queueResult:
(void)	- noteTaskQueued:
(id)	- init [implementation]
(void)	- completePendingTasks [implementation]
(void)	- waitForTaskToComplete: [implementation]
Instance Methods inherited from OOAsyncWorkManager
(BOOL)	- addTask:priority:
(void)	- dealloc [implementation]
(oneway void)	- release [implementation]
(id)	- retain [implementation]
(NSUInteger)	- retainCount [implementation]

Private Attributes
OOAsyncQueue *	_readyQueue
NSMutableSet *	_pendingCompletableOperations
NSLock *	_pendingOpsLock

Additional Inherited Members
Class Methods inherited from OOAsyncWorkManager
(OOAsyncWorkManager *)	+ sharedAsyncWorkManager
(id)	+ allocWithZone: [implementation]

Detailed Description

Definition at line 56 of file OOAsyncWorkManager.m.

Method Documentation

completePendingTasks

- (void) completePendingTasks

implementation

Reimplemented from OOAsyncWorkManager.

Definition at line 88 of file OOAsyncWorkManager.m.

{
    id next = nil;
    
    [_pendingOpsLock lock];
    for (;;)
    {
        next = [_readyQueue tryDequeue];
        if (next == nil)  break;
        
        [_pendingCompletableOperations removeObject:next];
        [next completeAsyncTask];
    }
    [_pendingOpsLock unlock];
}

init

- (id) init

implementation

Reimplemented in OOOperationQueueAsyncWorkManager.

Definition at line 88 of file OOAsyncWorkManager.m.

{
    if ((self = [super init]))
    {
        _readyQueue = [[OOAsyncQueue alloc] init];
        
        if (_readyQueue == nil)
        {
            [self release];
            return nil;
        }
        
        _pendingCompletableOperations = [[NSMutableSet alloc] init];
        _pendingOpsLock = [[NSLock alloc] init];
        
        if (_pendingCompletableOperations == nil || _pendingOpsLock == nil)
        {
            [self release];
            return nil;
        }
    }
    
    return self;
}

noteTaskQueued:

- (void) noteTaskQueued:

(id<OOAsyncWorkTask>)

task

Definition at line 88 of file OOAsyncWorkManager.m.

                       :(id<OOAsyncWorkTask>)task
{
    [_pendingOpsLock lock];
    [_pendingCompletableOperations addObject:task];
    [_pendingOpsLock unlock];
}

queueResult:

- (void) queueResult:

(id<OOAsyncWorkTask>)

task

Definition at line 88 of file OOAsyncWorkManager.m.

                    :(id<OOAsyncWorkTask>)task
{
    if ([task respondsToSelector:@selector(completeAsyncTask)])
    {
        [_readyQueue enqueue:task];
    }
}

waitForTaskToComplete:

- (void) waitForTaskToComplete: (id<OOAsyncWorkTask>)  task

implementation

Reimplemented from OOAsyncWorkManager.

Definition at line 88 of file OOAsyncWorkManager.m.

                              :(id<OOAsyncWorkTask>)task
{
    if (task == nil)  return;
    
#if OO_DEBUG
    NSParameterAssert([(id)task respondsToSelector:@selector(completeAsyncTask)]);
    NSAssert1(![NSThread respondsToSelector:@selector(isMainThread)] || [[NSThread self] isMainThread], @"%s can only be called from the main thread.", __PRETTY_FUNCTION__);
#endif
    
    [_pendingOpsLock lock];
    BOOL exists = [_pendingCompletableOperations containsObject:task];
    if (exists)  [_pendingCompletableOperations removeObject:task];
    [_pendingOpsLock unlock];
    
    if (!exists)  return;
    
    id next = nil;
    do
    {
        // Dequeue a task and complete it.
        next = [_readyQueue dequeue];
        [_pendingOpsLock lock];
        [_pendingCompletableOperations removeObject:next];
        [_pendingOpsLock unlock];
    
        [next completeAsyncTask];
        
    }  while (next != task);    // We don't control order, so keep looking until we get the one we care about.
}

Member Data Documentation

_pendingCompletableOperations

- (NSMutableSet*) _pendingCompletableOperations

private

Definition at line 61 of file OOAsyncWorkManager.m.

_pendingOpsLock

- (NSLock*) _pendingOpsLock

private

Definition at line 62 of file OOAsyncWorkManager.m.

_readyQueue

- (OOAsyncQueue*) _readyQueue

private

Definition at line 59 of file OOAsyncWorkManager.m.

---

The documentation for this class was generated from the following file:

• src/Core/OOAsyncWorkManager.m