Golang开发--Goroutine的使用

这篇具有很好参考价值的文章主要介绍了Golang开发--Goroutine的使用。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

Go 语言天生支持并发编程,提供了丰富的原语和工具来编写并发程序。Goroutine 是 Go 语言中的轻量级执行单位。它们是由 Go 运行时(runtime)管理的,并且能够在单个线程上运行成千上万个 Goroutine。创建 Goroutine 非常高效,可以通过使用关键字 go 启动一个新的 Goroutine。例如,go myFunction() 将 myFunction 作为一个 Goroutine 启动。

1.并发与并行:
并发是指同时处理多个任务的能力,而并行是指同时执行多个任务的能力。Go 语言通过 Goroutine 实现并发编程,可以轻松地创建和管理大量的 Goroutine。同时,Go 语言的运行时系统会在多个物理线程上调度 Goroutine,实现并行执行,以充分利用多核处理器的性能。

2.Channel:
通道(channel)是 Goroutine 之间进行通信和同步的关键机制。通道提供了安全的数据传输和共享的方式。Goroutine 可以通过通道发送和接收数据,从而实现协调和共享数据。通过使用通道,可以避免显式的锁和条件变量,从而简化并发编程。

3.并发安全:
Go 语言通过设计和约定来鼓励并发安全的编程。其中一个重要原则是不要通过共享内存来通信,而是通过通道来共享数据。通道的发送和接收操作在不同 Goroutine 之间提供了隐式的同步,避免了竞态条件和数据竞争。

4.同步原语:
Go 语言提供了丰富的同步原语来协调 Goroutine 的执行。其中包括互斥锁(Mutex)、读写锁(RWMutex)、条件变量(Cond)等。这些原语可以用于保护共享资源的访问,实现互斥和同步。

5.原子操作:
Go 语言提供了原子操作来执行不可分割的操作,从而避免竞态条件。原子操作可以保证在并发环境中对共享变量的读取和写入是原子性的,不会被中断。这些原子操作可以通过 sync/atomic 包进行使用。

6.Select 语句:
select 是 Go 语言中用于处理多个通道操作的语句。它可以同时监听多个通道的发送和接收操作,当其中任意一个操作准备就绪时,select 语句将执行相应的操作。select` 语句可以用于实现非阻塞的通信、超时控制和多路复用等场景。

7.WaitGroup:
sync.WaitGroup是 Go 语言中的一个同步原语,用于等待一组 Goroutine 完成执行。它可以用于在主程序中等待所有 Goroutine 完成后再继续执行。通过Add、Done和Wait` 方法,可以方便地管理 Goroutine 的并发执行。

通过以上的特性和工具,Go 语言提供了一种简洁而强大的方式来编写并发程序。它使得开发人员能够更轻松地实现并发、并行和多任务处理,从而充分利用多核处理器的性能,并提高程序的响应性和吞吐量。然而,在编写并发程序时,需要小心处理共享资源和同步问题,以确保程序的正确性和稳定性。

启动 Goroutine:

package main

import (
	"fmt"
	"time"
)

func printNumbers() {
	for i := 1; i <= 5; i++ {
		fmt.Println(i)
		time.Sleep(500 * time.Millisecond)
	}
}

func printLetters() {
	for i := 'a'; i <= 'e'; i++ {
		fmt.Println(string(i))
		time.Sleep(500 * time.Millisecond)
	}
}

func main() {
	go printNumbers()
	go printLetters()

	// 等待一段时间,以便 Goroutine 有足够的时间执行
	time.Sleep(3 * time.Second)

	fmt.Println("主程序结束")
}

在上述示例中,我们定义了两个函数 printNumbers 和 printLetters,它们分别打印数字和字母。通过使用关键字 go,我们在 main 函数中启动了两个 Goroutine 来执行这两个函数。主程序等待一段时间后结束,这给了 Goroutine 充足的时间来执行打印操作。

使用通道进行通信:

package main

import (
	"fmt"
	"time"
)

func worker(id int, jobs <-chan int, results chan<- int) {
	for job := range jobs {
		fmt.Printf("Worker %d 开始处理任务 %d\n", id, job)
		time.Sleep(1 * time.Second)
		fmt.Printf("Worker %d 完成任务 %d\n", id, job)
		results <- job * 2
	}
}

func main() {
	jobs := make(chan int, 5)
	results := make(chan int, 5)

	// 启动三个工作协程
	for i := 1; i <= 3; i++ {
		go worker(i, jobs, results)
	}

	// 发送任务到通道
	for i := 1; i <= 5; i++ {
		jobs <- i
	}
	close(jobs)

	// 接收工作协程处理结果
	for i := 1; i <= 5; i++ {
		result := <-results
		fmt.Println("任务结果:", result)
	}
}

在上述示例中,我们创建了两个通道 jobs 和 results,分别用于发送任务和接收结果。
jobs <-chan int 表示定义了一个名为 jobs 的 channel,该 channel 只能接收 int 类型的数据,并且 jobs 是一个只读的 channel。这意味着 jobs 可以被用于接收 int 类型的数据,但不能用于发送数据。
在 Go 语言中,<- 用于指定 channel 的方向,<-chan 表示只读 channel,chan<- 表示只写 channel,而不加方向表示读写 channel。
我们启动了三个工作协程(Goroutine)来处理任务。主程序将任务发送到 jobs 通道中,工作协程从 jobs 通道接收任务并处理,然后将结果发送到 results 通道中。主程序从 results 通道接收结果并打印。文章来源地址https://www.toymoban.com/news/detail-704826.html

到了这里,关于Golang开发--Goroutine的使用的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • golang中给数据库datetime格式赋值

    1、定义数据库表映射结构体如上,create_time字段在表里面是datetime格式。 2、如果CreateTime不给值,在存库时,create_time字段的值为NULL。 3、赋值时,如下代码

    2024年02月09日
    浏览(46)
  • golang 连接 oracle 数据库 增删改查

     1,golang 连接 oracle 数据库  2,增删改查

    2024年02月09日
    浏览(48)
  • golang web学习随便记4-内存、文件、数据库

    我们来开始学习如何存储数据。书中有一点不错,就是并不是一上来就告诉你存储数据使用数据库,因为不同的数据存储适合不同的手段。 先来看在内存中存储数据:下面的例子用结构体方式在内存存放数据,然后利用两个map来表示“索引”,键值对中的值是指向内存中结构

    2024年02月06日
    浏览(246)
  • Golang 程序漏洞检测利器 govulncheck(二):漏洞数据库详解

    上一篇文章详细介绍了 Golang 程序漏洞扫描工具 govulncheck 的使用方法,govulncheck 强大功能的背后,离不开 Go 漏洞数据库(Go vulnerability database)的支持,接下来详细讲解下 Go 漏洞数据库相关的知识。 在当今数字化的世界中,软件安全是至关重要的。随着 Golang 在开发领域的日

    2024年02月10日
    浏览(32)
  • golang协程goroutine教程

    项目经常遇到一些批量任务执行太慢,需要开启多线程去处理,记录下在 Golang 中协程使用的一些操作。 协程是计算机程序的一类组件,推广了协作式多任务的子例程,允许执行被挂起与被恢复。相对子例程而言,协程更为一般和灵活,但在实践中使用没有子例程那样广泛。

    2024年02月02日
    浏览(40)
  • golang Goroutine超时控制

     https://github.com/zeromicro/go-zero/blob/master/core/fx/timeout.go  一文搞懂 Go 超时控制_51CTO博客_go 超时处理

    2024年02月09日
    浏览(41)
  • golang学习-goroutine

    1、goroutine协程 goroutine 是 Go 语言支持并发的核心,一个goroutine会以一个很小的栈开始其生命周期,一般只需要2KB。区别于操作系统线程由系统内核进行调度, goroutine 是由Go运行时(runtime)负责调度。例如Go运行时会智能地将 m个goroutine 合理地分配给n个操作系统线程,实现类

    2024年01月18日
    浏览(40)
  • Golang中的协程(goroutine)

    目录 进程 线程 并发 并行 协程(goroutine)  使用sync.WaitGroup等待协程执行完毕 多协程和多线程         进程就是程序在操作系统中的一次执行过程,是系统进行资源分配和调度的基本单位,进程是一个动态概念,是程序在执行过程中分配和管理资源的基本单位,每一个进程

    2024年02月05日
    浏览(36)
  • 深入理解 Golang: Goroutine 协程

    进程用来分配内存空间,是操作系统分配资源的最小单位;线程用来分配 CPU 时间,多个线程共享内存空间,是操作系统或 CPU 调度的最小单位;协程用来精细利用线程。协程就是将一段程序的运行状态打包,可以在线程之间调度。或者说将一段生产流程打包,使流程不固定在

    2024年02月11日
    浏览(79)
  • Golang goroutine MPG 模式浅析

    快速入门小结: (1) 主线程是一个物理线程,直接作用在cpu上的 。是重量级的,非常耗费cpu资源。 (2)协程从主线程开局的,是轻量级的线程,是逻辑态,对资源消耗相对小。 (3)Golang的协程机制是重要的特点,可以轻松的开启上万个协程。其它编程语言的并发机制是

    2024年02月08日
    浏览(49)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包