美文网首页
使用调度组同时处理多个任务

使用调度组同时处理多个任务

作者: Brice_Zhao | 来源:发表于2016-10-18 00:06 被阅读35次

    假设你的应用在启动时必须向服务端进行一连串的请求.这些请求可能是获取配置信息.举个例子,当你的应用启动时可能会向服务端请求一些配置信息.这个配置信息可能需要多个请求组合而成.

    你想通过调用一个方法去启动这些请求,然后全部请求完成后,在一个completion block里面完成你的业务逻辑. 但是这些请求相互间没有什么联系,我们应该如何做呢? 常见的方式是使用调度组( dispatch group )来实现.

    初始化一个dispatch group

    dispatch_group_t serviceGroup = dispatch_group_create();
    

    向dispatch group中添加任务

    1. 是在这个dispatch group中添加你的代码块,然后这些代码块会运行在你指定的queue中.
    dispatch_group_async(serviceGroup,queue,^{
        // some work here
    });
    

    通过这样的方式我们可以:请求之后可以马上返回我们想要的数据,然后每个请求中都有自己的completion block。因为,当我们的“任务”完成的时候,dispatch group 会马上收到消息通知。

    2. 手动告诉dispatch group你要开始某个任务了.完成任务之后,你也需要手动退出dispath group.

    通过dispatch_group_enter(),dispatch_group_leave()两个方法可以实现进入,退出两个动作:

    dispatch_group_enter(serviceGroup);
    [configService startWithCompletion:^(ConfigResponse *results, NSError* error){
        // Do something with the error or results
        dispatch_group_leave(serviceGroup);
    }];
    

    每个enter都必须有相应的leave,否则,你的dispatch group永远不会结束.在你要去请求一个web service的时候,你先enter dispatch group,然后在返回的completion block中 leave.

    下面举例说明dispatch_group 如何处理多个任务

    -(void)fetchConfigurationWithCompletion:(void (^)(NSError* error))completion
    {
        // Define errors to be processed when everything is complete.
        // One error per service; in this example we'll have two 
        __block NSError *configError = nil;
        __block NSError *preferenceError = nil;
    
        // Create the dispatch group
        dispatch_group_t serviceGroup = dispatch_group_create();
    
        // Start the first service
        dispatch_group_enter(serviceGroup);
        [self.configService startWithCompletion:^(ConfigResponse *results, NSError* error){
            // Do something with the results
            configError = error;
            dispatch_group_leave(serviceGroup);
        }];
    
        // Start the second service
        dispatch_group_enter(serviceGroup);
        [self.preferenceService startWithCompletion:^(PreferenceResponse *results, NSError* error){
            // Do something with the results
            preferenceError = error;
            dispatch_group_leave(serviceGroup);
        }];
    
        dispatch_group_notify(serviceGroup,dispatch_get_main_queue(),^{
            // Assess any errors
            NSError *overallError = nil;
            if (configError || preferenceError)
            {
                // Either make a new error or assign one of them to the overall error
                overallError = configError ?: preferenceError;
            }
            // Now call the final completion block
            completion(overallError);
        });
    }
    

    相关文章

      网友评论

          本文标题:使用调度组同时处理多个任务

          本文链接:https://www.haomeiwen.com/subject/plvzyttx.html