Swift: 异步回调

22

我如何在Swift中进行异步回调?我正在为我的应用程序编写一个小框架,因为它应该在iOS和OS X上运行。因此,我将不特定于设备的主要代码放入了这个框架中,该框架还处理对我的在线API的请求。显然,我也希望应用程序的GUI(图形用户界面),因此我的ViewControllers可以在API请求完成后立即响应。在Objective-C中,我通过将包含需要调用的函数的视图保存在id变量中,并将函数本身保存在选择器变量中来实现这一点。然后,我使用以下代码调用该函数:

SEL selector = callbackMethod;
((void (*)(id, SEL))[callbackViewController methodForSelector:selector])(callbackViewController, selector);

我该如何在Swift中完成这个任务?或者有更好的方法吗?

非常感谢您的帮助!


1
只是想让你知道,你可以将Selector声明为字符串。例如:var mySelector:SEL =“somefunction:” - Duyen-Hoa
@tyt_g207 谢谢!这对我有用!请将其发布为答案,以便我可以接受它 :) - stoeffn
你的Objective-C代码可以简化为((void (*)(id, SEL))objc_msgSend)(callbackViewController, selector);或者只是[callbackViewController performSelector:selector]; - newacct
延续@newacct的评论,在Swift中可以使用以下代码:viewController.performSelector(onMainThread: selector, with: nil, waitUntilDone: false) - Noor
4个回答

30

我已经在下面的gist中分享了我在这种情况下使用的模式:https://gist.github.com/szehnder/84b0bd6f45a7f3f99306

基本上,我创建了一个名为DataProvider.swift的单例对象来设置一个AFNetworking客户端。然后视图控制器调用该DataProvider上的方法,每个方法都以我定义为ServiceResponse的闭包类型别名结束。这个闭包返回一个字典或一个错误。

通过这种方式,你可以非常清晰地从VC中调用异步数据操作,并明确指示当异步响应返回时要执行什么操作(在我看来)。

DataProvider.swift

typealias ServiceResponse = (NSDictionary?, NSError?) -> Void

class DataProvider: NSObject {

    var client:AFHTTPRequestOperationManager?
    let LOGIN_URL = "/api/v1/login"

    class var sharedInstance:DataProvider {
        struct Singleton {
            static let instance = DataProvider()
        }
        return Singleton.instance
    }

    func setupClientWithBaseURLString(urlString:String) {
        client = AFHTTPRequestOperationManager(baseURL: NSURL.URLWithString(urlString))
        client!.operationQueue = NSOperationQueue.mainQueue()
        client!.responseSerializer = AFJSONResponseSerializer()
        client!.requestSerializer = AFJSONRequestSerializer()
    }

    func loginWithEmailPassword(email:String, password:String, onCompletion: ServiceResponse) -> Void {
        self.client!.POST(LOGIN_URL, parameters: ["email":email, "password":password] , success: {(operation:AFHTTPRequestOperation!, responseObject:AnyObject!) -> Void in

            self.setupClientWithBaseURLString("http://somebaseurl.com")

            let responseDict = responseObject as NSDictionary
                // Note: This is where you would serialize the nsdictionary in the responseObject into one of your own model classes (or core data classes)
                onCompletion(responseDict, nil)
            }, failure: {(operation: AFHTTPRequestOperation!, error:NSError!) -> Void  in
                onCompletion(nil, error)
            })
    }
}

MyViewController.swift

import UIKit

class MyViewController: UIViewController {

    override func viewDidLoad() {
        super.viewDidLoad()

        // Do any additional setup after loading the view.
    }

    override func viewWillAppear(animated: Bool)  {
        super.viewWillAppear(animated)
        DataProvider.sharedInstance.loginWithEmailPassword(email:"some@email.com", password:"somepassword") { (responseObject:NSDictionary?, error:NSError?) in

            if (error) {
                println("Error logging you in!")
            } else {
                println("Do something in the view controller in response to successful login!")
            }
        }
    }  
}

我现在已经实现了你的方法,它可以工作。但是当尝试在回调中更改UI时,出现了非常奇怪的行为:例如,无法显示警报,并且控制台显示“不得从后台线程执行布局引擎的修改”。此外,视图本身的图形更改会延迟几秒钟,尽管与这些更改相关的代码立即执行。我该如何解决这些问题?你有什么想法吗? - stoeffn
1
我使用dispatch_async(dispatch_get_main_queue(), { ... })解决了这个问题。 - stoeffn
如果实际闭包声明“ServiceResponse”具有返回类型Void,那么说“此闭包返回字典或错误”是否准确?难道不应该说闭包有两个参数,一个是NSDictionary类型,另一个是NSError类型吗? - riik
1
如果我们已经在使用JavaScript回调函数,为什么不同时采用它的约定呢?callback(err, data)而不是callback(data, err) - bicycle
最好将operationQueue属性设置为除了mainQueue队列之外的其他队列。并且特别在主线程上执行完成块。解析将在后台队列上执行,这对于fps来说总是更好的。 - art-divin

24
我建议使用块或闭包回调,而不是使用NSThread和选择器。
例如,在我的API中,我有一个follow方法: Swift: 下面是更新后的实现。
func getUsers(completion: (result: NSArray?, error: NSError?)->())
{
    var session = NSURLSession.sharedSession()
    var task = session.dataTaskWithRequest(request){
     (data, response, error) -> Void in
       if error != nil {
         completion(nil, error)
       } else {
         var result:NSArray = data to NSArray;
         completion(result, nil)
       }
    }
    task.resume()
}

Objective-C:

...
typedef void (^CBSuccessBlock)(id result);
typedef void (^CBFailureBlock)(NSError *error);
...

- (void)usersWithSucces:(CBSuccessBlock)success failure:(CBFailureBlock)failure
{
    NSURLSession *session = [NSURLSession sharedSession];
    [[session dataTaskWithURL:[NSURL URLWithString:url]
            completionHandler:^(NSData *data,
                                NSURLResponse *response,
                                NSError *error) {

                NSArray *users = //convert data to array

                if(error)
                    failure(error);
                else
                    success(users);
            }] resume];
}

然后,只需要从视图控制器中调用API:
Objc:
[api usersWithSucces:^(id result)
{
   //Success callback
} failure:^(NSError *error)
{
   //Failure callback
}];

Swift:
api.getUsers({(result: AnyObject?, error: NSError?) -> Int in
    // callback here
})

更新:

与此同时,我发现这个问题和答案仍然有用并且令人感兴趣。下面是使用泛型枚举作为结果对象的Swift实现的更新版本:

//Generic enum that represents the result
enum AsyncResult<T>
{
    case Success(T)
    case Failure(NSError?)
}


class CustomUserObject
{

}

func getUsers(completion: (AsyncResult<[CustomUserObject]>)->())
{
    let request = NSURLRequest()
    let session = NSURLSession.sharedSession()
    let task = session.dataTaskWithRequest(request){
        (data, response, error) -> Void in
        if let error = error
        {
            completion(AsyncResult.Failure(error))
        } else {
            let result: [CustomUserObject] = []//deserialization json data into array of [CustomUserObject]
            completion(AsyncResult.Success(result))
        }
    }
    task.resume()
}

//Usage:

getUsers { (result) in
    switch result
    {
    case .Success(let users):
        /* work with users*/
        break
    case .Failure(let error):
        /* present an error */
        break
    }
}

4

我刚刚做了这个小例子: Swift:异步回调块模式示例

基本上有一个ClassA:

//ClassA it's the owner of the callback, he will trigger the callback when it's the time
class ClassA {
    //The property of that will be associated to the ClassB callback
    var callbackBlock : ((error : NSError?, message : String?, adress : String? ) -> Void)?

    init() {
        //Do Your staff
    }

    //Define your function with the clousure as a parameter
    func yourFunctionWithCallback(#functionCallbackParameter : (error : NSError?,message : String?, adress : String?) -> ()) {
        //Set the calback with the calback in the function parameter
        self.callbackBlock = functionCallbackParameter
    }

    //Later On..
    func callbackTrigger() {
        self.callbackBlock?(error: nil,message: "Hello callback", adress: "I don't know")

    }
}

而且 ClassB:

//ClassB it's the callback reciver the callback
class ClassB {
    @IBAction func testCallbackFunction(sender: UIButton) {
        let classA = ClassA()
        classA.yourFunctionWithCallback { (error, message, adress) -> () in
            //Do your stuff
        }
    }
}
ClassA: 它拥有一个属性 callbackBlock。ClassB 将通过调用 yourFunctionWithCallback 函数来设置此属性。稍后,当 ClassA 准备就绪时,将通过在 callbackTrigger 函数内调用 callBackBlock 来触发回调。 ClassB: 将调用 ClassA 方法来设置回调块,并等待块被触发。

0

NSThread能帮助你吗?:

NSThread.detachNewThreadSelector(<#selector: Selector#>, toTarget: <#AnyObject?#>, withObject: <#AnyObject?#>) 

网页内容由stack overflow 提供, 点击上面的
可以查看英文原文,
原文链接