游乐游手机版
首页/编程语言/文章详情

在Ubuntu系统上使用Golang实现并发控制的完整教程

时间:2026-06-17 06:39
在Ubuntu环境下,Go通过goroutines和channels实现并发控制。用go关键字启动轻量级协程,主函数不等待其完成,需借助sync WaitGroup或延时才能观察到执行效果,否则主进程可能提前退出导致协程未运行。

在Go语言中,说起并发控制,最核心的无外乎 goroutines 和 channels 这对搭档。goroutines 可以理解为轻量级的线程,能让你在程序中同时跑多个任务,而 channels 则负责在它们之间传递数据和同步协调。下面就在 Ubuntu 环境下,用几个实际例子来拆解 Go 的并发控制思路。

golang在ubuntu如何实现并发控制

go 关键字启动一个 goroutine

最直接的方式——在函数调用前加上 go,这个函数就会在新 goroutine 里跑。但要注意,主函数不会等待它执行完毕,所以通常需要加一点延时才能看到效果。

package main

import (
	"fmt"
	"time"
)

func printNumbers() {
	for i := 1; i <= 5; i++ {
		fmt.Printf("Number: %d\n", i)
		time.Sleep(1 * time.Second)
	}
}

func main() {
	go printNumbers()
	time.Sleep(6 * time.Second)
}

sync.WaitGroup 优雅地等待所有 goroutine 结束

真实场景下不可能靠 time.Sleep 来硬等。标准库的 sync.WaitGroup 就是干这个的:每启动一个 goroutine 就调用 wg.Add(1),任务完成后用 wg.Done() 通知,最后通过 wg.Wait() 阻塞直到所有任务收工。

package main

import (
	"fmt"
	"sync"
	"time"
)

func printNumbers(wg *sync.WaitGroup) {
	defer wg.Done()
	for i := 1; i <= 5; i++ {
		fmt.Printf("Number: %d\n", i)
		time.Sleep(1 * time.Second)
	}
}

func main() {
	var wg sync.WaitGroup
	wg.Add(1)
	go printNumbers(&wg)
	wg.Wait()
}

channel 在 goroutines 之间传递数据

如果多个 goroutine 需要互相通信,channel 是最自然的桥梁。下面例子先往带缓冲的 chan 里塞入 5 个数字,然后关闭 channel,再启动一个 goroutine 去接收并打印它们——这种“生产者-消费者”模式在并发编程中非常常见。

package main

import (
	"fmt"
	"time"
)

func printNumbers(numbers chan int) {
	for num := range numbers {
		fmt.Printf("Number: %d\n", num)
		time.Sleep(1 * time.Second)
	}
}

func main() {
	numbers := make(chan int, 5)
	for i := 1; i <= 5; i++ {
		numbers <- i
	}
	close(numbers)
	go printNumbers(numbers)
	time.Sleep(6 * time.Second)
}

sync.Mutex 保护共享资源

当多个 goroutine 同时读写同一个变量时(比如计数器),数据竞争在所难免。这时候就需要一把互斥锁来保证同一时刻只有一个 goroutine 能操作共享数据。下面代码启动 10 个 goroutine 并发递增 counter,通过 sync.Mutex 确保最终结果正确。

package main

import (
	"fmt"
	"sync"
	"time"
)

var counter int
var mutex sync.Mutex

func incrementCounter() {
	mutex.Lock()
	defer mutex.Unlock()
	counter++
}

func main() {
	wg := sync.WaitGroup{}
	for i := 0; i < 10; i++ {
		wg.Add(1)
		go func() {
			defer wg.Done()
			incrementCounter()
		}()
	}
	wg.Wait()
	fmt.Printf("Counter: %d\n", counter)
}

这几个例子覆盖了 Go 并发控制中最基础也最实用的套路:直接启动 goroutine、用 WaitGroup 统一等待、用 channel 做通信、用 Mutex 保护临界区。根据实际场景选对工具,并发代码就能写得既清晰又安全。

来源:https://www.yisu.com/ask/78089531.html
上一篇Ubuntu下Golang性能调优实用方法 下一篇Ubuntu系统下如何配置Golang日志系统详细步骤完整教程
本站内容用于信息整理与展示,如有侵权或内容问题请及时联系处理。

相关推荐

补充同频道和同主题内容,方便继续浏览更多相关内容。

同类最新

继续查看同栏目最近更新的文章。

更多
如何在ThinkPHP中实现定时任务与命令行调度方法
编程语言 · 2026-07-04

如何在ThinkPHP中实现定时任务与命令行调度方法

用ThinkPHP实现定时任务时,很多开发者第一步就卡在命令行报错上,直接输入php think your:command却无法识别——这种情况绝大多数是因为命令类的注册方式存在问题。下面先梳理几个核心要点。 ThinkPHP 6 中 think 命令如何正确触发自定义指令 直接运行 php thi

ThinkPHP API接口防重放攻击实现方法
编程语言 · 2026-07-04

ThinkPHP API接口防重放攻击实现方法

先说几个核心判断:API防重放攻击这件事,做对了是道防火墙,做错了就是个心理安慰。很多开发者到踩坑了才明白——验签这东西,放错位置、漏掉字段、存错nonce,每一环都能让整个安全体系直接归零。 验签必须放在中间件里,不能在控制器里写 ThinkPHP 的请求生命周期中,中间件是唯一能在路由匹配、参数

ThinkPHP文件上传必须验证扩展名安全必要性分析
编程语言 · 2026-07-04

ThinkPHP文件上传必须验证扩展名安全必要性分析

在使用ThinkPHP进行文件上传时,ext扩展名验证通常是开发者首先接触的关键环节。但你真的了解它的实际工作原理吗?它仅比对文件名后缀,而不读取文件内容,甚至对空格和大小写都极其敏感。更为重要的是——它是TP文件上传验证五层防线中不可忽视的第一道关卡,一旦配置遗漏,整个validate验证链将直接

ThinkPHP关联模型自动写入与更新使用教程
编程语言 · 2026-07-04

ThinkPHP关联模型自动写入与更新使用教程

需要明确的是,ThinkPHP关联模型并没有提供所谓的“自动写入 更新”魔法开关。所谓的“自动”功能,实际上都需要开发者手动编写配置逻辑才能生效。核心原则在于:主模型和从模型必须分开独立处理,时间戳字段和业务字段需依靠修改器或钩子接管;批量操作则要规规矩矩地绕过模型逻辑来执行——只有理解透彻这些要点

BoxLayout中仅居中一个组件其他默认左对齐
编程语言 · 2026-07-04

BoxLayout中仅居中一个组件其他默认左对齐

在 Java Swing 中使用 BoxLayout 的 Y_AXIS 方向布局时,很多初学者容易掉进一个常见陷阱:希望将某个组件单独设置为中心对齐,但当调用 `setAlignmentX(CENTER_ALIGNMENT)` 后,却发现其他组件也跟着发生了偏移,完全达不到预期效果。实际上,关键之处