4

我像疯了一样在谷歌上搜索，仍然对此感到困惑。

我想将一组文件 url 下载到磁盘，并且我想根据每个文件在下载时加载的字节来更新我的视图。我已经有了可以下载文件并通过块报告进度和完成的东西。

如何为数组中的每个文件执行此操作？

我可以一次做一个。我可以通过这种方式轻松计算总进度：

float progress = (numCompletedFiles + (currentDownloadedBytes / currentTotalBytes)) / totalFiles)

我主要了解 GCD 和 NSOperations，但是如何告诉操作或 dispatch_async 块等到回调被调用后再完成？重写 NSOperation 似乎是可能的，但这似乎有点矫枉过正。还有其他方法吗？只用GCD可以吗？

4

3 回答 3

16

我不确定我是否正确理解您，但也许您需要调度信号量来实现您的目标。在我的一个项目中，我使用调度信号量来等待另一位玩家完成另一个回合。这部分是我使用的代码。

for (int i = 0; i < _players.count; i++)
{

    // a semaphore is used to prevent execution until the asynchronous task is completed ...

    dispatch_semaphore_t sema = dispatch_semaphore_create(0);


    // player chooses a card - once card is chosen, animate choice by moving card to center of board ...

    [self.currentPlayer playCardWithPlayedCards:_currentTrick.cards trumpSuit:_trumpSuit completionHandler:^ (WSCard *card) {

        BOOL success = [self.currentTrick addCard:card];

        DLog(@"did add card to trick? %@", success ? @"YES" : @"NO");

        NSString *message = [NSString stringWithFormat:@"Card played by %@", _currentPlayer.name];
        [_messageView setMessage:message];

        [self turnCard:card];
        [self moveCardToCenter:card];


        // send a signal that indicates that this asynchronous task is completed ...

        dispatch_semaphore_signal(sema);

        DLog(@"<<< signal dispatched >>>");
    }];


    // execution is halted, until a signal is received from another thread ...

    DLog(@"<<< wait for signal >>>");

    dispatch_semaphore_wait(sema, DISPATCH_TIME_FOREVER);
    dispatch_release(sema);


    DLog(@"<<< signal received >>>");
于 2013-02-04T23:53:37.880 回答
7

调度组是 GCD 工具，旨在跟踪一组独立或单独异步块/任务的完成情况。

要么使用 dispatch_group_async() 提交有问题的块，要么在触发异步任务之前使用 dispatch_group_enter() 组，并在任务完成时使用 dispatch_group_leave() 组。

然后，当组中的所有块/任务都完成时，您可以通过 dispatch_group_notify() 异步获得通知，或者如果必须，您可以使用 dispatch_group_wait() 同步等待完成。

于 2013-02-05T06:28:00.833 回答
0

我只是想指出，我确实通过继承 NSOperation 并使其成为“并发”操作来使其工作。（在这种情况下，并发是指在将其标记为完成之前应该等待的异步操作）。

http://www.dribin.org/dave/blog/archives/2009/05/05/concurrent_operations/

基本上，您在子类中执行以下操作

  1. 覆盖start以开始您的操作
  2. 覆盖isConcurrent返回YES
  3. 完成后，确保 isExecuting 和 isFinished 更改正确，以符合键值的方式（基本上，调用willChangeValueForKey:和didChangeValueForKey:isFinishedisExecuting

在包含队列的类中

  1. 设置为maxConcurrentOperationCount_NSOperationQueue1
  2. 在所有并发操作之后添加一个操作，一旦它们全部完成就会触发
于 2013-02-05T15:51:24.260 回答