使用 Dispatch Source 而不使用 dispatch_async 的唯一原因就是利用联结的优势。
联结的大致流程：在任一线程上调用它的一个函数 dispatch_source_merge_data 后，会在相应quene执行 Dispatch Source 事先定义好的句柄（可以把句柄简单理解为一个 block ）。
这个过程叫 Custom event ，用户事件。是 dispatch source 支持处理的一种事件。
简单地说，这种事件是由你调用 dispatch_source_merge_data 函数来向自己发出的信号。
一、创建dispatch源
dispatch_source_t source = dispatch_source_create(DISPATCH_SOURCE_TYPE_DATA_ADD, 0, 0, dispatch_get_main_queue());
参数:
| 参数 | 意义 |
|---|---|
| type | dispatch源可处理的事件类型 |
| handle | 可以理解为索引、id或句柄，假如要监听进程，需要传入进程的ID |
| mask | 可以理解为描述，提供更详细的描述，让它知道具体要监听什么 |
| queue | 自定义源需要的一个队列，用来处理所有的响应句柄（block） |
Dispatch Source可处理的所有事件:
| 名称 | 意义 |
|---|---|
| DISPATCH_SOURCE_TYPE_DATA_ADD | 自定义的事件，变量增加 |
| DISPATCH_SOURCE_TYPE_DATA_OR | 自定义的事件，变量OR |
| DISPATCH_SOURCE_TYPE_MACH_SEND | MACH端口发送 |
| DISPATCH_SOURCE_TYPE_MACH_RECV | MACH端口接收 |
| DISPATCH_SOURCE_TYPE_PROC | 进程监听,如进程的退出、创建一个或更多的子线程、进程收到UNIX信号 |
| DISPATCH_SOURCE_TYPE_READ | IO操作，如对文件的操作、socket操作的读响应 |
| DISPATCH_SOURCE_TYPE_SIGNAL | 接收到UNIX信号时响应 |
| DISPATCH_SOURCE_TYPE_TIMER | 定时器 |
| DISPATCH_SOURCE_TYPE_VNODE | 文件状态监听，文件被删除、移动、重命名 |
| DISPATCH_SOURCE_TYPE_WRITE | IO操作，如对文件的操作、socket操作的写响应 |
自定义事件可以使用的只有DISPATCH_SOURCE_TYPE_DATA_ADD和DISPATCH_SOURCE_TYPE_DATA_OR这两种类型，我们这里也只讨论这两种类型。
二、其他函数:
dispatch_suspend(queue) //挂起队列
dispatch_resume(source) //分派源创建时默认处于挂起状态，在分派源分派处理程序之前必须先恢复
dispatch_source_merge_data(source, 1) //向分派源发送事件，需要注意的是，不可以传递0值(事件不会被触发)，同样也不可以传递负数。
dispatch_source_set_event_handler(source, block) //设置响应分派源事件的block，在分派源指定的队列上运行
dispatch_source_get_data(source) //得到分派源的数据
三、代码:
//创建source，以DISPATCH_SOURCE_TYPE_DATA_ADD的方式进行累加，而DISPATCH_SOURCE_TYPE_DATA_OR是对结果进行二进制或运算
dispatch_source_t source = dispatch_source_create(DISPATCH_SOURCE_TYPE_DATA_ADD, 0, 0, dispatch_get_main_queue());
//设置事件触发后执行的句柄
dispatch_source_set_event_handler(source,^{
NSLog(@"监听函数：%lu",dispatch_source_get_data(source));
});
//开启source
dispatch_resume(source);
dispatch_queue_t myqueue =dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);
dispatch_async(myqueue, ^ {
for(int i = 1; i <= 4; i ++){
NSLog(@"~~~~~~~~~~~~~~%d", i);
//异步线程触发事件，向source发送事件，这里i不能为0，否则触发不了事件
dispatch_source_merge_data(source,i);
//当Interval的事件越长，则每次的句柄都会触发
//[NSThread sleepForTimeInterval:1.0];
}
});
上面的这个例子，因为for循环运算速度非常快，系统会自动把这4次事件联结起来，可以看到最终事件触发的句柄只会执行一次。打印出来的结果为:
~~~~~~~~~~~~~~1
~~~~~~~~~~~~~~2
~~~~~~~~~~~~~~3
~~~~~~~~~~~~~~4
监听函数：10
这里的10就是把每次的事件值i相加得到的(1+2+3+4)。这里如果把DISPATCH_SOURCE_TYPE_DATA_ADD替换为DISPATCH_SOURCE_TYPE_DATA_OR，结果会是7，也就是把每次的事件值i或运算得到(1|2|3|4)。
如果把[NSThread sleepForTimeInterval:1.0]的注释打开，因为事件间隔太长，系统不会联结，此时类似于dispatch_async()，打印结果如下：
~~~~~~~~~~~~~~1
监听函数：1
~~~~~~~~~~~~~~2
监听函数：2
~~~~~~~~~~~~~~3
监听函数：3
~~~~~~~~~~~~~~4
监听函数：4
此时不论type是DISPATCH_SOURCE_TYPE_DATA_ADD或DISPATCH_SOURCE_TYPE_DATA_OR，结果都是这个，因为这两种type只影响联结时的value。对非联结的情况没有影响。
四、例子:
当我们更新进度条时，可能在多个线程上同时做很多任务，每个任务完成后，刷新界面，更新一点进度条的进度，因为每个任务都更新一次进度条，造成界面刷新次数太多，可能会导致界面卡顿，所以此时利用Dispatch Source能很好的解决这种情况，因为Dispatch Source在刷新太频繁的时候会自动联结起来，下面就用代码实现一下这个场景。
//1、指定DISPATCH_SOURCE_TYPE_DATA_ADD，做成Dispatch Source(分派源)。设定Main Dispatch Queue 为追加处理的Dispatch Queue
dispatch_source_t source = dispatch_source_create(DISPATCH_SOURCE_TYPE_DATA_ADD, 0, 0, dispatch_get_main_queue());
__block NSUInteger totalComplete = 0;
dispatch_source_set_event_handler(source, ^{
//当处理事件被最终执行时，计算后的数据可以通过dispatch_source_get_data来获取。这个数据的值在每次响应事件执行后会被重置，所以totalComplete的值是最终累积的值。
NSUInteger value = dispatch_source_get_data(source);
totalComplete += value;
NSLog(@"进度：%@", @((CGFloat)totalComplete/100));
});
//分派源创建时默认处于暂停状态，在分派源分派处理程序之前必须先恢复。
dispatch_resume(source);
dispatch_queue_t queue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);
for (NSUInteger index = 0; index < 100; index++) {
dispatch_async(queue, ^{
usleep(20000);//0.02秒
dispatch_source_merge_data(source, 1);
});
}
上面相等于启动了100个任务，每个任务耗时0.02秒，打印结果如下：
进度：0.25
进度：0.32
进度：0.37
进度：0.41
进度：0.55
进度：0.61
进度：0.63
进度：0.64
进度：0.76
进度：0.89
进度：0.96
进度：1
附上demo。
