go 协程返回值处理操作

IT行业相对于一般传统行业，发展更新速度更快，一旦停止了学习，很快就会被行业所淘汰。所以我们需要踏踏实实的不断学习，精进自己的技术，尤其是初学者。今天golang学习网给大家整理了《go 协程返回值处理操作》，聊聊GO协程、返回值，我们一起来看看吧！

我就废话不多说了，大家还是直接看代码吧~

package main
import "fmt"
import "sync"
var ch = make(chan int)
func do(lock *sync.Mutex, ct *int) {
 lock.Lock()
 *ct++
 lock.Unlock()
 ch 

<p><code>输出: 10</code></p>
<p><strong>补充：Goroutine协程之间的数据沟通的方式</strong></p>
<p>一个服务器物理线程能够跑多个goroutine，成千上万个goroutine 实际上跑在物理线程上的也就几十个，但是java和c++创建成千上万个线程会使得系统反应更慢，这是为什么goroutine能很快的原因。</p>
<p>那么goroutine协程之间是如何进行通信的呢？有两种方式，</p>
<p>第一使用全局变量和锁同步：读写锁或互斥锁对全局变量进行加锁，实现多个goroute的数据共享。</p>
<p>第二：Channel 管道进行数据同步</p>
<h3>1.加锁操作</h3>
<p>互斥锁就是将公共资源进行加锁操作，以便于goroute对数据进行更改。</p>

<pre class="brush:plain;">
package main 
import (
 "fmt"
 lock "sync"
 "time"
)
 
type task struct {
 n int
}
 
//通过全局的 map 来通讯
var (
 sum 
)
 
func calc(t *task) {
 var sum uint64
 sum = 1
 for i := 1; i 

<h3>2.channel管道通信</h3>
<p>单纯地将函数并发执行是没有意义的。函数与函数间需要交换数据才能体现并发执行函数的意义。虽然可以使用共享内存进行数据交换，但是共享内存在不同的 goroutine 中容易发生竞态问题。为了保证数据交换的正确性，必须使用互斥量对内存进行加锁，这种做法势必造成性能问题。</p>
<p>Go 语言提倡使用通信的方法代替共享内存，这里通信的方法就是使用通道（channel）</p>
<p><strong>channel 具有几个特性：</strong></p>
<p>1.类似unix中的管道（pipe）</p>
<p>2.先进先出</p>
<p>3.线程安全，多个goroutine同时访问，不需要加锁</p>
<p>4.channel是有类型的，一个整数的channel 只能存放整</p>
<p><strong>2.1使用通道发送数据</strong></p>
<p>通道创建后，就可以使用通道进行发送和接收操作。</p>
<p>1) 通道发送数据的格式</p>
<p>通道的发送使用特殊的操作符
</p><p>通道变量 
</p><p>通道变量：通过make创建好的通道实例。</p>
<p>值：可以是变量、常量、表达式或者函数返回值等。值的类型必须与ch通道的元素类型一致。</p>
<p>2) 通过通道发送数据的例子</p>
<p>使用 make 创建一个通道后，就可以使用

</p><pre class="brush:plain;">
// 创建一个空接口通道
ch := make(chan interface{})
// 将0放入通道中
ch 

<p><strong>2.2 使用通道接收数据</strong></p>
<p>1)通道接收同样使用
</p><p>① 通道的收发操作在不同的两个 goroutine 间进行。</p>
<p>由于通道的数据在没有接收方处理时，数据发送方会持续阻塞，因此通道的接收必定在另外一个 goroutine 中进行。</p>
<p>② 接收将持续阻塞直到发送方发送数据。</p>
<p>如果接收方接收时，通道中没有发送方发送数据，接收方也会发生阻塞，直到发送方发送数据为止</p>
<p>③ 每次接收一个元素。</p>
<p>通道一次只能接收一个数据元素。</p>
<p>通道的数据接收一共有以下 4 种写法。</p>
<p>2) 阻塞接收数据</p>
<p>阻塞模式接收数据时，将接收变量作为
</p><p><code>data := </code></p>
<p>执行该语句时将会阻塞，直到接收到数据并赋值给 data 变量。</p>
<p>3) 非阻塞接收数据</p>
<p>使用非阻塞方式从通道接收数据时，语句不会发生阻塞，格式如下：</p>
<p><code>data, ok := </code></p>
<p>data：表示接收到的数据。未接收到数据时，data 为通道类型的零值。</p>
<p>ok：表示是否接收到数据。</p>
<p>非阻塞的通道接收方法可能造成高的 CPU 占用，因此使用非常少。如果需要实现接收超时检测，可以配合 select 和计时器 channel 进行，可以参见后面的内容。</p>
<p>4) 接收任意数据，忽略接收的数据</p>
<p>阻塞接收数据后，忽略从通道返回的数据，格式如下：</p>
<p><code></code></p>
<p>执行该语句时将会发生阻塞，直到接收到数据，但接收到的数据会被忽略。这个方式实际上只是通过通道在 goroutine 间阻塞收发实现并发</p>
<p><strong>2.3 发生阻塞的2种情况</strong></p>
<p>1）发送方发送阻塞：在通道数据没有接收方处理时，通道的数据一开始会存放到固定的数据缓冲区内，超出缓冲区的大小将发生持续阻塞。</p>

<pre class="brush:plain;">
package main 
func main() {
 var ch chan int
 ch = make(chan int, 5) //定义数据缓存区设置为5个大小
 //将数据保存在缓冲区内并不会发生当前线程阻塞
 for i := 0; i 

<p>这个程序的执行结果直接painc 因为在管道加入ch 
</p><p>2） 数据接收方发生阻塞：如果接收方没有接收到数据，接收方等待发送方发送数据，等待的过程也会使数据接收的协程发生阻塞。</p>

<pre class="brush:plain;">
package main 
import (
 "fmt"
 "time"
)
 
func main() { 
 var ch chan int
 ch = make(chan int) //无定义数据缓存区
 
 go func() { 
 var a = 

<p>这个程序的执行结果是延时4秒后控制台打印出通道的值1，5秒后主程序结束。上边的程序是先让接收者协程开启等待接收通道的值，而发送者是主函数延迟4秒后才将值放入通道ch,匿名函数中不得不等待发送者的值，所以造成了匿名并发函数的阻塞。 我们可以思考到，如果去掉4秒等待的时间， 这个程序就是使用channel作为协程之间同步的最简单的例子，我们发现channel同步的特性就是无数据缓存区。</p>
<p>同样一个程序，当你把接受者 go func() 程序放到 ch

</p><pre class="brush:plain;">
package main 
import (
 "fmt"
 "time"
)
 
func main() { 
 var ch chan int
 ch = make(chan int) //无定义数据缓存区
 
 //time.Sleep(time.Second * 4) //主线程等待4才给管道数据
 
 ch 

<p>以上为个人经验，希望能给大家一个参考，也希望大家多多支持golang学习网。如有错误或未考虑完全的地方，望不吝赐教。</p><p>终于介绍完啦！小伙伴们，这篇关于《go 协程返回值处理操作》的介绍应该让你收获多多了吧！欢迎大家收藏或分享给更多需要学习的朋友吧~golang学习网公众号也会发布Golang相关知识，快来关注吧！</p>