Nice way to run on specific queues

[ide]

One of the things that Bolts does pretty well is let you choose a queue to run a block on, while this is manual with PromiseKit. I think it'd be useful to be able to write:

dispatch_queue_t queue = ...;
dispatch_promise(queue, ^{
    return [self makeValueAsync];
}).then(dispatch_get_main_queue(), ^(id value) {
    [self.view displayValue:value];
    return [self logDisplayInfo:self.view];
}).then(^{
    // No queue specified: synchronously run on the same queue immediately after
    // logDisplayInfo's promise is resolved
});

Also Bolts has an "executor" abstraction that runs blocks. Executors might be more general than needed but the default executors are useful to have:

• dispatch_async to the main queue
• dispatch_async to the default-pri background queue
• run synchronously on the current queue where the previous task finished

[mxcl]

Yes, I'll add the choose-a-queue variant, and probably add an NSOperationQueue category too.

For other kinds of "executor" I'll wait for people to propose additions or use cases.

[ide]

Wonderful!

[mxcl]

I started to consider the NSOperation variant and wasn't sure if it should be a category on NSOperationQueue or a subclass of NSOperation and what should then happen with then (ie. should the then's be operations also? If so, the complexity increases).

But as you can see above, I committed dispatch_promise_on.

[ide]

A category of NSOperationQueue seems more flexible than subclassing NSOperation e.g. it accomodates projects that already subclass NSOperation. From my experience using Bolts, one of the most important features was being able to choose the dispatch queue / NSOperationQueue to run a block so being able to do that in PromiseKit would be good.

For then, I think it's simplest to always return a Promise and later add a convenience method to convert Promises to NSOperations.

[mxcl]

As an additional note, I will make it possible for then to specify a queue (like your example code shows) as part of this ticket.

[maximkhatskevich]

"I will make it possible for then to specify a queue" -->> Max, tell me please, when do you think this feature will be ready and available via CocoaPods?

[mxcl]

As soon as I can figure out how to do it elegantly. I can't really estimate that well, but I really would like to get this in ASAP.

[maximkhatskevich]

Okay, thanks. Look forward to it. In the mean time, does current implementation execute each then block in chain on Main queue?

For example:

dispatch_promise(^{
    return md5(email); // main queue???
}).then(^(NSString *md5){
    return [NSURLConnection GET:@"http://gravatar.com/%@", md5];  // main queue???
}).then(^(UIImage *gravatarImage){
    self.imageView.image = gravatarImage;  // main queue???
});

Explain please how can I know on which thread/queue a block in the chain would be executed?

[mxcl]

dispatch_promise is documented to run on a background queue. It thens onto the main queue.

There is also dispatch_promise_on if you need a specific queue. Also documented.

There is currently no guarantees about the queue a then runs on, it depends on the implementation of the Promise, it's just currently they all then onto main.

Thus to achieve your current goals you can do this for now:

somepromise.then(^{
    return dispatch_promise(^{
        //…
    });
}).then(^{
    return dispatch_promise(^{
        //…
    });
});

Not pretty, but works for now. Naturally this will mean the main queue is always used as an intermediate, but that should be fine under most circumstances. Just not ideal.

[maximkhatskevich]

Okay, thank you very much for the explanation!

[yvbeek]

Perhaps this notation would work?

dispatch_queue_t myQueue = dispatch_queue_create(...);

dispatch_promise(^{
    return md5(email);
}).thenOn(myQueue, ^(NSString *md5){
    return [NSURLConnection GET:@"http://gravatar.com/%@", md5];
}).then(^(UIImage *gravatarImage){
    self.imageView.image = gravatarImage;
});

By the way, nice design on the block methods!

[mxcl]

@ZyphraX yes, I like that.

[maximkhatskevich]

@mxcl I would suggest to allow set a queue (lets name it defaultQueue) where to process all the blocks by default at promise constructor and allow specify queue as a parameter to change target queue for a particular "then"/block. Also use dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0) (system background concurrent queue) by default (I mean use it if no defaultQueue specified explicitly at promise creation time). I think this would be the most flexible way to implement it, because you give full control on where (on which queue) each block is being processed.

For most cases you can specify needed queue only twice (at creation time and at last block) like this:

dispatch_queue_t myQueue = dispatch_queue_create(...); // custom queue

dispatch_promise(myQueue, ^{
    return md5(email); // myQueue
}).thenOn(^(NSString *md5){
    return [NSURLConnection GET:@"http://gravatar.com/%@", md5]; // myQueue
}).then(dispatch_get_main_queue(), ^(UIImage *gravatarImage){
    self.imageView.image = gravatarImage; // dispatch_get_main_queue(),
});

... or even once (if you it is okay to perform everything on DEFAULT concurrent system queue except last block where you set explicitly MAIN queue) like this:

dispatch_promise(^{
    return md5(email); // default queue
}).thenOn(^(NSString *md5){
    return [NSURLConnection GET:@"http://gravatar.com/%@", md5]; // default queue
}).then(dispatch_get_main_queue(), ^(UIImage *gravatarImage){
    self.imageView.image = gravatarImage; // dispatch_get_main_queue(),
});