在 go 并发环境中，集成外部语言函数可以使用 cgo 包（调用 c 代码）或 ffi（跨语言调用）实现。实战案例中，我们创建了一个并发执行器来调用 python 函数，使用互斥锁同步对共享结果变量的访问。
在 Go 并发环境中集成外部语言函数
Go 语言为并发编程提供了强大的支持，使其能够轻松地构建并行和高效的应用程序。然而，有时我们需要在 Go 应用程序中集成由其他语言编写的函数。本文将探讨在 Go 并发环境中集成外部语言函数的技巧和实战案例。
使用 cgo
cgo 是 Go 语言中一个特殊的包，允许将 Go 代码与 C 代码进行交互。它通过编译 C 代码并将其与 Go 代码链接起来，从而提供了直接调用 C 函数的能力。
package main
import "C"
func main() {
C.puts(C.CString("Hello, world!"))
}在此示例中，C.puts 是 C 语言的 puts 函数，它输出一个字符串。
|Git删除了文件，但还会在Git 仓库历史中遗留。 - 想要从 Git 历史移除敏感信息（密码、密钥、token、私钥） - 想要删除意外提交的大文件 - 想要重写 Git 历史、移除特定文件的所有痕迹 - 提到 "force push"、"重写 commit 历史" - 需要从所有分支、所有 tag 中删除某个文件
使用 FFI
除了 cgo 之外，我们还可以使用外函数接口 (FFI) 在 Go 中调用非 Go 函数。FFI 提供了一种跨语言调用的标准化方法，可以使用 C 语言或汇编语言编写。
package main
import "syscall"
func main() {
syscall.Syscall(syscall.SYS_WRITE, syscall.Stdout, c.CString("Hello, world!"), len("Hello, world!"))
}在此示例中，syscall.Syscall 系统调用用于直接调用系统内核函数，在本例中为 SYS_WRITE，它将数据写入标准输出。
实战案例：调用 Python 函数
为了展示如何在并发环境中集成外部语言函数，让我们创建一个 Go 应用程序来调用 Python 函数。
设置
- 使用
pip安装 Python 库：pip install numpy - 编写 Python 函数：
import numpy as np
def multiply(x, y):
return np.multiply(x, y)Go 代码
package main
import (
"context"
"fmt"
"log"
"sync"
"github.com/glycerine/goexec/executor"
)
var (
result int
resultMu sync.Mutex
)
func main() {
// 创建具有 10 个工作进程的上下文
ctx, cancel := context.WithCancel(context.Background())
executor, err := executor.Start(executor.Options{
MaxConcurrency: 10,
})
if err != nil {
log.Fatalf("无法启动执行器：%v", err)
}
defer cancel()
// 创建等待组来等待子任务完成
var wg sync.WaitGroup
// 并发地调用 Python 函数
for i := 0; i < 10000; i++ {
wg.Add(1)
go func(i int) {
defer wg.Done()
// 设置 Python 函数参数
args := []string{
"-c",
fmt.Sprintf("import numpy; print(numpy.multiply(10, %d))", i),
}
// 调用 Python 函数
output, err := executor.RunCommand(ctx, "python", args...)
if err != nil {
log.Printf("无法运行 Python 命令：%v", err)
return
}
// 解析输出
fmt.Sscanf(string(output), "%d", &result)
// 使用互斥锁更新结果
resultMu.Lock()
result += result
resultMu.Unlock()
}(i)
}
wg.Wait()
fmt.Printf("最终结果：%d\n", result)
}在此示例中，我们使用 goexec 库创建了一个并发执行器，并使用 context 和 WaitGroup 来管理并发调用。我们还使用了互斥锁来同步对共享结果变量的访问。
