我希望能够序列化“真正的”异步方法,例如:
- 发起网络请求
- 显示一个 UIAlertView
这通常是一项棘手的工作,大多数串行队列示例在 NSBlockOperation 的 block 中显示“ sleep ”。这是行不通的,因为操作只有在回调发生时才完成。
我已经尝试通过子类化 NSOperation 来实现它,这里是实现中最有趣的部分:
+ (MYOperation *)operationWithBlock:(CompleteBlock)block
{
MYOperation *operation = [[MYOperation alloc] init];
operation.block = block;
return operation;
}
- (void)start
{
[self willChangeValueForKey:@"isExecuting"];
self.executing = YES;
[self didChangeValueForKey:@"isExecuting"];
if (self.block) {
self.block(self);
}
}
- (void)finish
{
[self willChangeValueForKey:@"isExecuting"];
[self willChangeValueForKey:@"isFinished"];
self.executing = NO;
self.finished = YES;
[self didChangeValueForKey:@"isExecuting"];
[self didChangeValueForKey:@"isFinished"];
}
- (BOOL)isFinished
{
return self.finished;
}
- (BOOL) isExecuting
{
return self.executing;
}
效果很好,这是一个演示...
NSOperationQueue *q = [[NSOperationQueue alloc] init];
q.maxConcurrentOperationCount = 1;
dispatch_queue_t queue = dispatch_queue_create("1", NULL);
dispatch_queue_t queue2 = dispatch_queue_create("2", NULL);
MYOperation *op = [MYOperation operationWithBlock:^(MYOperation *o) {
NSLog(@"1...");
dispatch_async(queue, ^{
[NSThread sleepForTimeInterval:2];
NSLog(@"1");
[o finish]; // this signals we're done
});
}];
MYOperation *op2 = [MYOperation operationWithBlock:^(MYOperation *o) {
NSLog(@"2...");
dispatch_async(queue2, ^{
[NSThread sleepForTimeInterval:2];
NSLog(@"2");
[o finish]; // this signals we're done
});
}];
[q addOperations:@[op, op2] waitUntilFinished:YES];
[NSThread sleepForTimeInterval:5];
请注意,我还使用了 sleep ,但确保它们在后台线程中执行以模拟网络调用。日志内容如下
1...
1
2...
2
如愿以偿。这种方法有什么问题?有什么我应该注意的注意事项吗?
最佳答案
“序列化”异步任务实际上将被命名为“延续”(另请参阅此 wiki 文章 Continuation。
假设,您的任务可以定义为带有完成处理程序的异步函数/方法,其参数是异步任务的最终结果,例如:
typedef void(^completion_handler_t)(id result);
-(void) webRequestWithCompletion:(completion_handler_t)completionHandler;
-(void) showAlertViewWithResult:(id)result completion:(completion_handler_t)completionHandler;
拥有blocks可用,通过从上一个任务的完成 block 中调用下一个异步任务可以轻松完成“继续”:
- (void) foo
{
[self webRequestWithCompletion:^(id result) {
[self showAlertViewWithResult:result completion:^(id userAnswer) {
NSLog(@"User answered with: %@", userAnswer);
}
}
}
注意方法 foo
被“异步”感染;)
也就是说,这里是方法的最终效果foo
,即将用户的答案打印到控制台,实际上也是异步的。
但是,“链接”多个异步任务,即“继续”多个异步任务,可能会很快变得笨拙:
使用完成 block 实现“延续”将增加每个任务的完成处理程序的缩进。此外,实现一种让用户在任何状态下取消任务的方法,并实现处理错误情况的代码,代码很快就会变得困惑,难以编写和理解。
实现“继续”以及取消和错误处理的更好方法是使用 Futures or Promises 的概念。 . Future 或 Promise 表示异步任务的最终结果。基本上,这只是一种向调用站点“发出最终结果信号”的不同方法。
在 Objective-C 中,“Promise”可以作为普通类来实现。有第三方图书馆实现“ promise ”。以下代码使用了特定的实现,RXPromise。
在使用这样的Promise 时,您可以按如下方式定义您的任务:
-(Promise*) webRequestWithCompletion;
-(Promise*) showAlertViewWithResult:(id)result;
注意:没有完成处理程序。
使用Promise,异步任务的“结果”将通过“成功”或“错误”处理程序获得,该处理程序将“注册”到then
。 promise 的属性(property)。成功或错误处理程序在任务完成时被调用:当它成功完成时,成功处理程序将被调用,将其结果传递给成功处理程序的参数 result。否则,当任务失败时,它会将原因传递给错误处理程序——通常是 NSError
。对象。
Promise 的基本用法如下:
Promise* promise = [self asyncTasks];
// register handler blocks with "then":
Promise* handlerPromise = promise.then( <success handler block>, <error handler block> );
成功处理程序 block 有一个类型为 id
的参数 result .错误处理程序 block 有一个类型为 NSError
的参数.
注意语句promise.then(...)
返回一个代表任一处理程序结果的 promise ,当“父” promise 已成功或错误地解决时调用它。处理程序的返回值可以是“立即结果”(某个对象)或“最终结果”——表示为 Promise 对象。
以下代码片段(包括复杂的错误处理)显示了 OP 问题的注释示例:
- (void) foo
{
[self webRequestWithCompletion] // returns a "Promise" object which has a property "then"
// when the task finished, then:
.then(^id(id result) {
// on succeess:
// param "result" is the result of method "webRequestWithCompletion"
return [self showAlertViewWithResult:result]; // note: returns a promise
}, nil /*error handler not defined, fall through to the next defined error handler */ )
// when either of the previous handler finished, then:
.then(^id(id userAnswer) {
NSLog(@"User answered with: %@", userAnswer);
return nil; // handler's result not used, thus nil.
}, nil)
// when either of the previous handler finished, then:
.then(nil /*success handler not defined*/,
^id(NEError* error) {
// on error
// Error handler. Last error handler catches all errors.
// That is, either a web request error or perhaps the user cancelled (which results in rejecting the promise with a "User Cancelled" error)
return nil; // result of this error handler not used anywhere.
});
}
代码当然需要更多的解释。有关详细和更全面的描述,以及如何在任何时间点完成取消,您可以查看 RXPromise library - 实现“Promise”的 Objective-C 类。披露:我是 RXPromise 库的作者。
关于ios - 在 Objective-C 中序列化异步任务,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/18202952/