Блог

1. возникает ли какая-либо проблема в следующем коде при тайм-ауте (без регистра ARC)?

2. как насчет того, что dispatch_semaphore_signal вызывается после dispatch_release(семафор)? Я знаю, что объект отправки асинхронно освобождается после освобождения всех ссылок на него (счетчик ссылок становится равным нулю), поэтому ссылка на семафор не равна 0 в следующем коде?

3. необходимо ли добавлять __block для семафора?

         dispatch_time_t timeout = DISPATCH_TIME_FOREVER;
        if (waitTime > 0)
        {            
            timeout = dispatch_time(DISPATCH_TIME_NOW, waitTime * NSEC_PER_SEC);
        }
        dispatch_semaphore_t semaphore = dispatch_semaphore_create(0);  
        dispatch_barrier_async(_dispatchQueue, ^{
            dispatch_semaphore_signal(semaphore);
        });
   
        dispatch_semaphore_wait(semaphore, timeout);
        dispatch_release(semaphore);
     

большое спасибо!

На основе комментариев.

Я думаю, вам нужно что-то вроде этого. done Переменная должна быть синхронизирована / атомарна, и в коде есть два места, которые необходимо синхронизировать с некоторой общей блокировкой. На самом деле, поскольку вы получаете доступ только done к этим частям, синхронизировать их не нужно.

 done = NO

dispatch_barrier ...
   stuff
   sync {
     if(!done)
       signal
       done = YES;
   }

wait with timeout
cancel block
sync {
  if( ! done )
    signal
    done = YES
}

// You can even test the logic as below
if DEBUG
{
  assert done == YES
}

release
  

Я не уверен, какое влияние окажет блок отмены в среде, отличной от ARC, но думаю, что все будет хорошо.

Это сбалансирует сигналы и ожидания и заставит релиз работать, а также не позволит вам сигнализировать о выпущенном семафоре.

Вот примерная реализация в Objective-C

     __block BOOL done = NO;
    NSObject * lock = NSObject.new;
    dispatch_semaphore_t s = dispatch_semaphore_create ( 0 );
    dispatch_queue_t queue = dispatch_queue_create( "bak",
                               dispatch_queue_attr_make_with_qos_class( DISPATCH_QUEUE_CONCURRENT,
                                                   QOS_CLASS_DEFAULT,
                                                   DISPATCH_QUEUE_PRIORITY_DEFAULT ) );

    dispatch_block_t block = dispatch_block_create ( DISPATCH_BLOCK_BARRIER, ^ {

        // Change this time to determine which one fires first
        [NSThread sleepForTimeInterval:1];

        @synchronized ( lock ) {

            if ( ! done )
            {
                done = YES;
                dispatch_semaphore_signal ( s );
                NSLog ( @"Inside fired" );
            }

        }

    } );

    // Start the block
    dispatch_async ( queue, block );

    // ... or change time here to determine which one fires first
    dispatch_semaphore_wait ( s, dispatch_time ( DISPATCH_TIME_NOW, 2 * NSEC_PER_SEC ) );

    @synchronized ( lock ) {

        if ( ! done )
        {
            done = YES;
            dispatch_semaphore_signal ( s );
            NSLog ( @"Outside fired" );
        }

    }

    // Done, release stuff *only* if not ARC
    dispatch_release ( s );
    dispatch_release ( queue );
    dispatch_release ( block );
    lock.release;