OOAsyncQueue(OOPrivate) Category Reference

Instance Methods
(void)	- doEmptyQueueWithAcquiredLock
(id)	- doDequeAndUnlockWithAcquiredLock
(void)	- recycleElementWithAcquiredLock:

Detailed Description

Definition at line 80 of file OOAsyncQueue.m.

Method Documentation

doDequeAndUnlockWithAcquiredLock

- (id) doDequeAndUnlockWithAcquiredLock

Extends class OOAsyncQueue.

Definition at line 64 of file OOAsyncQueue.m.

{
    OOAsyncQueueElement     *element = NULL;
    id                      result;
    
    if (_head == NULL)
    {
        // Can happen if you enter debugger.
        return nil;
    }
    
//  assert(_head != NULL);
    
    // Dequeue element.
    element = _head;
    _head = _head->next;
    if (_head == NULL)  _tail = NULL;
    --_elemCount;
    
    // Unpack payload.
    result = [element->object autorelease];
    
    // Recycle element.
    [self recycleElementWithAcquiredLock:element];
    
    // Ensure sane status.
    assert((_head == NULL && _tail == NULL && _elemCount == 0) || (_head != NULL && _tail != NULL && _elemCount != 0));
    
    // Unlock with appropriate state.
    [_lock unlockWithCondition:(_head == NULL) ? kConditionNoData : kConditionQueuedData];
    
    return result;
}

doEmptyQueueWithAcquiredLock

- (void) doEmptyQueueWithAcquiredLock

Extends class OOAsyncQueue.

Definition at line 64 of file OOAsyncQueue.m.

{
    OOAsyncQueueElement     *element = NULL;
    
    // Loop over queue.
    while (_head != NULL)
    {
        // Dequeue element.
        element = _head;
        _head = _head->next;
        --_elemCount;
        
        // We don't need the payload any longer.
        [element->object release];
        
        // Or the element.
        [self recycleElementWithAcquiredLock:element];
    }
    
    _tail = NULL;
}

recycleElementWithAcquiredLock:

- (void) recycleElementWithAcquiredLock:

(OOAsyncQueueElement *)

element

Extends class OOAsyncQueue.

Definition at line 64 of file OOAsyncQueue.m.

                                      :(OOAsyncQueueElement *)element
{
    if (_poolCount < kMaxPoolElements)
    {
        // Add to pool for reuse.
        element->next = _pool;
        _pool = element;
        ++_poolCount;
    }
    else
    {
        // Delete.
        FreeElement(element);
    }
}

---

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

• src/Core/OOAsyncQueue.m