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

Ubuntu中Golang并发编程怎么写

时间:2026-05-05 11:07
在Ubuntu中编写Golang并发程序 想在Ubuntu系统里玩转Golang的并发编程?其实核心就是掌握好goroutines和channels这两个原语。下面通过一个具体的例子,带你走一遍完整的流程,看看如何让多个任务在Ubuntu环境下协同工作。 第一步:环境准备 首先,确保你的Ubuntu

在Ubuntu中编写Golang并发程序

想在Ubuntu系统里玩转Golang的并发编程?其实核心就是掌握好goroutines和channels这两个原语。下面通过一个具体的例子,带你走一遍完整的流程,看看如何让多个任务在Ubuntu环境下协同工作。

Ubuntu中Golang并发编程怎么写

第一步:环境准备

首先,确保你的Ubuntu系统已经安装了Golang。如果还没安装,直接去官网(https://golang.org/dl/)下载对应版本的安装包,按照指引完成安装即可。

第二步:创建项目文件

接下来,创建一个新的Go文件,比如就叫它 main.go,然后用你喜欢的文本编辑器打开它。

第三步:编写并发代码

main.go 文件中,输入以下代码:

package main

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

func main() {
    var wg sync.WaitGroup

    // 创建一个channel,用于在goroutines之间传递数据
    dataChan := make(chan int)

    // 启动一个goroutine,用于向channel发送数据
    wg.Add(1)
    go func() {
        defer wg.Done()
        for i := 0; i < 5; i++ {
            dataChan <- i
            time.Sleep(1 * time.Second)
        }
        close(dataChan)
    }()

    // 启动另一个goroutine,用于从channel接收数据并处理
    wg.Add(1)
    go func() {
        defer wg.Done()
        for data := range dataChan {
            fmt.Println("Received data:", data)
        }
    }()

    // 等待所有goroutines完成
    wg.Wait()
    fmt.Println("All goroutines finished.")
}

这段代码做了几件关键的事:它使用 sync.WaitGroup 来确保主程序等待所有“子任务”完成。同时,创建了一个名为 dataChan 的通道(channel),作为goroutines之间的数据传输管道。代码启动了两个goroutine:一个负责每隔一秒向通道发送一个数字,发送完毕后会关闭通道;另一个则持续从通道接收数据并打印出来。这种“生产者-消费者”模式是并发编程中的经典场景。

第四步:编译与运行

保存好文件后,打开终端,切换到文件所在目录,运行下面这条命令:

go run main.go

第五步:观察结果

现在,观察终端的输出。你会看到两个goroutine在同时运行:一个在后台默默发送数据,另一个则实时接收并打印出这些数据。整个过程是并发进行的,而不是顺序执行。

通过这个简单的示例,你应该对在Ubuntu中使用Golang进行并发编程有了一个直观的感受。当然,这只是个起点。你可以基于这个模式,修改和扩展代码,来实现更复杂的并发逻辑,比如处理更多任务、使用带缓冲的通道,或者引入更精细的同步机制。关键在于理解goroutine的轻量和channel的通信能力,剩下的就是你的想象力了。

来源:https://www.yisu.com/ask/77080133.html
上一篇Ubuntu Golang网络编程怎么实现 下一篇Golang在Ubuntu上的单元测试怎么写
本站内容用于信息整理与展示,如有侵权或内容问题请及时联系处理。

相关推荐

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

同类最新

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

更多
如何在Go中安全地创建和使用time.Ticker最佳实践指南
编程语言 · 2026-07-06

如何在Go中安全地创建和使用time.Ticker最佳实践指南

在Go中,time Ticker的创建位置直接影响并发安全。最佳实践是在goroutine外创建或完全限定在单个goroutine内使用,严禁无保护跨goroutine共享。无论采用哪种方式,都必须在使用完毕后调用Stop()释放底层定时器资源,防止goroutine泄露。停止后的Ticker不应再调用Reset以避免竞态。

Go跨文件cgo结构体类型不兼容的解决方案
编程语言 · 2026-07-06

Go跨文件cgo结构体类型不兼容的解决方案

cgo为每个Go包生成独立的C命名空间,导致跨文件使用同一C结构体时类型不兼容。解决方案是在中心包中定义Go封装类型(如typePointC point_t),并将所有构造、访问和业务逻辑封装其中,其他包仅引用Go类型,避免直接暴露C类型。

Go语言有符号整数二进制补码的正确输出方法
编程语言 · 2026-07-06

Go语言有符号整数二进制补码的正确输出方法

Go语言fmt Printf的%b格式对负数输出带负号的绝对值二进制,而非底层补码位模式。需注意,通过将相同位宽的有符号整数转换为无符号类型(例如将int8转为uint8),可获取真实的二进制补码比特序列,如-5输出11111011,即其补码。

Python列表按出现顺序批量替换重复字符串
编程语言 · 2026-07-06

Python列表按出现顺序批量替换重复字符串

Python列表遍历中,使用计数器对重复字符串(如“latest png”)按出现顺序依次替换为带递增编号的新字符串(如“latest1 png”),保持原列表不变。该方法时间复杂度O(n),无需额外库,严格匹配避免误改,不修改原始列表。

Go语言中如何正确读取io.Reader避免重复与内存污染
编程语言 · 2026-07-06

Go语言中如何正确读取io.Reader避免重复与内存污染

Go开发者使用io Reader Read()手动读取HTTP响应体时,因忽略实际读取字节数n和未正确处理io EOF,导致内容重复、空字节污染等问题。必须使用buf[:n]追加有效数据,将io EOF视为正常终止信号,并检查其他错误,从而避免内存污染与panic风险。