golang使用channel实现归并排序的merge

本质：给定两个有序的channel， 然后将其合并为一个有序的channel

已知：

• 如果管道满了，但是数据没有读取就会一直阻塞
• 如果函数结束了，那么管道一定要被关闭，如果没有关闭就会fatal

前提：两个channle中存放的数据是有序的

两个channel，无论这两个channel什么时候将数据放入，放入了哪些数据【两个管道中的数据是有序的】

• 如果两个管道都没有被关闭
  • 管道1的第一个数据比较小，将这个数据读取到结果管道中。【此时管道2被阻塞】，读取完成之后，继续试图读取管道1
  • 否则，将管道2中的数据读取到结果管道中。【此时管道1被阻塞】，读取完成之后，继续试图读取管道2
  • 直到有一个管道被关闭了或者两个管道都被关闭了
• 如果管道1没有关闭&& 管道2被关闭了
  • 将管道1中的数据读取到结果管道中
• 如果管道1被关闭了&& 管道2没有关闭
  • 将管道2中的数据读取到结果管道中
• 如果两个管道都被关闭
  • 关闭结果管道，退出程序

package mainimport ("fmt""runtime"
)func main() {ch1 := create([]int{1, 2, 3, 4, 5, 6, 7, 8, 9})ch2 := create([]int{ 2, 3, 4, 5, 15, 15, 16, 17, 18, 19})ch := Merge(ch1, ch2)//range可以对channel进行迭代，不断接收channel里的数据（没有数据时阻塞），直到channel被关闭后自动退出迭代。for c := range ch {fmt.Print(c , "\t")}for {runtime.GC()}fmt.Scanln()
}// cha<- 只用来接受的管道
// <-chan: 只用来发送的管道
func create(arr []int) <-chan int {/*对于unbufferd channel，不存储任何数据，只负责数据的流通，并且数据的接收一定发生在数据发送完成之前。更详细的解释是，goroutine A在往channel发送数据完成之前，一定有goroutine B在等着从这个channel接收数据，否则发送就会导致发送的goruntine被block住，所以发送和接收的goruntine是耦合的*/out := make(chan int)  //单个goruntine中不要使用buffered channel来做缓存队列，send和receive操作很容让goruntine被永久block住导致整个程序死锁go func() {for _, v := range arr {out <- v //channel携带的数据只能被一个goruntine得到，一个goruntine取走数据后这份数据在channel里就不复存在了。}// 如果不关闭channel,会引发panicclose(out)}()return out
}// ch1 && ch2都必须是有序channel。  这里chan被当成是先进先出管道
func Merge(ch1, ch2 <-chan int) chan int { // ch1, ch2 被当成是先进先出队列。ch := make(chan int, 1024)go func() {v1, ok1 := <- ch1 //检查Channel是否已经被关闭了v2, ok2 := <- ch2 //检查Channel是否已经被关闭了for  ok1 || ok2 { //只要有一个管道没有被关闭，就会一直循环if ok1 && ok2 { // 当两个管道都没有被关闭时： 哪个小就将哪个数据读取到结果数据中if v1 < v2 {  // 判断这两个数据哪个小ch <- v1 // 就把小的数据从原来管道中读出来，然后放入结果管道ch中v1, ok1 = <- ch1  // 然后接着试图去读取小的哪个}else{ch <- v2v2, ok2 = <- ch2}}else if ok1 && ! ok2{ // ch1没有关闭：ch <- v1 // 从ch1中读取数据，然后放入结果管道ch中v1, ok1 = <- ch1  // 不断的从没有关闭的ch1}else{ch <- v2v2, ok2 = <- ch2}}close(ch) // 两个管道中的数据都被取完了}()return ch
}