Блог

Я добавляю много блочных операций в очередь операций в цикле for. В каждой операции мне нужно проверять в другом потоке, выполнено ли условие. Если условие выполнено, все операции должны быть отменены.

Я сделал пример кода, чтобы показать вам мою проблему:

 __block BOOL queueDidCancel = NO;
NSArray *array = [NSArray arrayWithObjects:@"1",@"2",@"3",@"4",@"5",@"6",@"7",@"8",@"9",@"10", nil];

NSOperationQueue *myQueue = [NSOperationQueue new];
myQueue.maxConcurrentOperationCount =1;


for (NSString *string in array) {
    [myQueue addOperationWithBlock:^{
        if (queueDidCancel) {return;}
        NSLog(@"run: %@", string);
        dispatch_async(dispatch_get_global_queue( DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
            if ([string isEqualToString:@"1"]) {
                queueDidCancel = YES;
                [myQueue cancelAllOperations];
            }
        });
    }];
}
  

Ожидаемый результат от NSLog:

 run: 1
  

Результат, который я получил (он варьируется от 7 до 9):

 run: 1
run: 2
run: 3
run: 4
run: 5
run: 6
run: 7
run: 8
  

Я часами гуглил, но не мог найти решение.

Я думаю, что нашел решение. Вот обновленный код:

 NSArray *array = [NSArray arrayWithObjects:@"1",@"2",@"3",@"4",@"5",@"6",@"7",@"8",@"9",@"10", nil];

NSOperationQueue *myQueue = [NSOperationQueue new];
myQueue.maxConcurrentOperationCount =1;


for (NSString *string in array) {
    [myQueue addOperationWithBlock:^{
        [myQueue setSuspended:YES];
        NSLog(@"run: %@", string);
        dispatch_async(dispatch_get_main_queue(), ^{
            if (![string isEqualToString:@"1"]) {
                [myQueue setSuspended:NO];
            }
        });
    }];
}
  

Позвольте мне использовать больше места. Вам необходимо синхронизировать доступ к вашей переменной. Это правильная идея, но вы используете ее неправильно. Вам нужна блокировка или атомарный ivar или что-то в этом роде, чтобы синхронизировать доступ к нему.

Затем, если вы отмените бит dispatch_async, это произойдет очень скоро после выполнения всех блоков. Это то, что показывает ваш вывод. Как упоминалось в комментарии, если вы добавите NSLog, например

 dispatch_async(dispatch_get_main_queue(), ^{
            if ([string isEqualToString:@"1"]) {
                queueDidCancel = YES;
                // Add here
                NSLog(@"Going to cancel now");
                [myQueue cancelAllOperations];
            }
  

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

Но самая большая проблема — это ваша логика. Вам нужна некоторая логика, чтобы отменить эти блоки. Просто обмен cancelAllOperations сообщениями или setSuspended недостаточно, и блоки, которые уже запущены, будут продолжать выполняться.

Вот краткий пример.

 NSObject * lock = NSObject.new;      // Use this to sync access
__block BOOL queueDidCancel = NO;

NSOperationQueue *myQueue = [NSOperationQueue new];
myQueue.maxConcurrentOperationCount =1;

for (NSString *string in array) {
    // Here you also need to add some logic, e.g. as below
    // Note the sync access
    @synchronized ( lock ) {
      if (queueDidCancel) { break; }
    }

    [myQueue addOperationWithBlock:^{

        // You need to sync access to queueDidCancel especially if
        // you access it from main and the queue or if you increase
        // the concurrent count
        // This lock is one way of doing it, there are others
        @synchronized ( lock ) {
          // Here is your cancel logic! This is fine here
          if (queueDidCancel) {return;}
        }

        NSLog(@"run: %@", string);

        dispatch_async(dispatch_get_main_queue(), ^{

            if ([string isEqualToString:@"1"]) {
                // Again you need to sync this
                @synchronized ( lock ) {
                  queueDidCancel = YES;
                }
                // This is not needed your logic should take care of it ...
                // The problem is that running threads will probably
                // keep on running and you need logic to stop them
                // [myQueue cancelAllOperations];
            }
        });
    }];
}
  

Теперь этот пример делает то, что делает ваш, но с немного большей блокировкой и немного большей логикой, без отменыопераций и приостановки = да. Это не будет делать то, что вы хотите, поскольку даже при этом запущенные потоки, как правило, выполняются до завершения, и вам нужна логика, чтобы остановить это.

Кроме того, в этом примере я оставил условие выхода или отмены, как в основном потоке. Опять же, здесь это, вероятно, будет означать, что ничего не отменяется, но в реальной жизни вы обычно отменяете из какого-либо пользовательского интерфейса, например, нажатием кнопки, а затем делаете это, как здесь . Но вы можете отменить где угодно, используя блокировку.

Редактировать

Основываясь на множестве комментариев, вот еще один возможный способ.

Здесь вы проверяете внутри блока и на основе проверки добавляете еще один блок или нет.

     NSOperationQueue * queue = NSOperationQueue.new;

    // Important
    queue.maxConcurrentOperationCount = 1;

    void ( ^ block ) ( void ) = ^ {

        // Whatever you have to do ... do it here
        xxx

        // Perform check
        // Note I run it sync and on the main queue, your requirements may differ
        dispatch_sync ( dispatch_get_main_queue (), ^ {

            // Here the condition is stop or not
            // YES means continue adding blocks
            if ( cond )
            {
                [queue addOperationWithBlock:block];
            }
            // else done

        } );

    };

    // Start it all
    [queue addOperationWithBlock:block];
  

Выше я каждый раз использую один и тот же блок, что также является предположением, но вы можете легко изменить его, чтобы добавить разные блоки. Однако, если все блоки одинаковы, вам понадобится только один, и вам не нужно продолжать планировать новые блоки, а затем можно сделать это, как показано ниже.

     void ( ^ block1 ) ( void ) = ^ {

        // Some logic
        __block BOOL done = NO;

        while ( ! done )
        {
            // Whatever you have to do ... do it here
            xxx

            // Perform check
            // Note I run it sync and on the main queue, your requirements may differ
            dispatch_sync ( dispatch_get_main_queue (), ^ {

                // Here the condition is stop or not
                // YES means stop! here
                done = cond;

            } );
        }

    };