Skip to content
Browse files


  • Loading branch information...
sdgandhi committed May 22, 2017
1 parent 4a6da52 commit 050aaa77c9fe1a274951df64d34a0211fa01725e
Showing with 9 additions and 10 deletions.
  1. +9 −10
@@ -9,7 +9,7 @@
<img title="Build status" src="">

## Overview

`SYNQueue` is a subclass of `NSOperationQueue` so you get:

@@ -26,22 +26,22 @@
- Queue specific logging (via protocol)
- Retries (exponential back-off)

## Motivation
With a good queuing solution you can provide a much better user experience in areas such as:

- Web requests
- Saving/creating content (images, video, audio)
- Uploading data

## Architecture
When we started building `SYNQueue`, persistence was the most important feature for us since we hadn't seen a good generic implementation of it anywhere. With that in mind, we designed each `SYNQueueTask` (`:NSOperation`) to hold just metadata about the task rather than code itself.

The actual code to perform the task gets passed to the queue in the form of a `taskHandler` closure. Each `SYNQueueTask` must have a `taskType` key which corresponds to a specific `taskHandler`.

##Example Code
## Example Code
For a thorough example see the demo project in the top level of the repository.

###Create a queue
### Create a queue
let queue = SYNQueue(queueName: "myQueue", maxConcurrency: 2, maxRetries: 3,
logProvider: ConsoleLogger(), serializationProvider: NSUserDefaultsSerializer(),
@@ -54,29 +54,28 @@ let queue = SYNQueue(queueName: "myQueue", maxConcurrency: 2, maxRetries: 3,
>The `completionBlock` is the block to run when a task in the queue completes (success or failure).
###Create a task
### Create a task
let t1 = SYNQueueTask(queue: queue, taskID: "1234", taskType: "uploadPhoto", dependencyStrs: [], data: [:])

>The `queue` is the queue you will add the task to. `taskID` is a unique ID for the task. `taskType` is the generic type of task to perform. Each `taskType` will have its own `taskHandler`. `data` is any data your task will need to perform its job.
###Add dependencies
### Add dependencies
let t2 = SYNQueueTask(queue: queue, taskID: "5678", taskType: "submitForm", dependencyStrs: [], data: [:])

###Add it to the queue
### Add it to the queue

>Notice that even though we add task `t2` to the queue first, it will not execute until its dependency, `t1` has finished executing.`
##An important note on persistence
## An important note on persistence
You may have realized that you are free to serialize tasks however you like through the `SYNQueueSerializationProvider` protocol. **The one caveat is that all tasks must be idempotent.** That is, even if called multiple times, the outcome of the task should be the same. For example: `x = 1` is idempotent, `x++` is not.

Hopefully this makes sense given that a serialized task may get interrupted before it finishes, and when we deserialize this task we will run it again. We only remove the serialized task after it has completed (success or failure).

0 comments on commit 050aaa7

Please sign in to comment.
You can’t perform that action at this time.