golang协成里写回调

2024-10-16 20:39:38 编程来源：ZONE.CI 全球网 0 阅读模式

Go语言（Golang）是Google开发的一套编程语言，非常适合构建高性能的网络服务。在Golang中，协程是一种轻量级的线程模型，与传统的线程相比具有更小的内存开销和更高的并发能力。协程中的回调函数是Golang非常重要的一部分，它可以让我们在异步执行的过程中处理返回结果或错误信息。

什么是回调函数

回调函数是指在一个函数中调用另外一个函数，并将其作为参数传递进去，等待被调用函数执行完毕后再执行回调函数。回调函数通常用于异步编程中，当一个函数的执行需要一段时间时，我们可以将这段时间的耗时操作放在一个新的协程中执行，然后在回调函数里处理函数的返回结果或错误信息。

在协程中使用回调函数

Golang中的协程通过关键字go来创建，协程的执行独立于主线程，可以并发执行。在协程中使用回调函数，只需要将回调函数作为参数传入协程的匿名函数中即可。

下面是一个简单的例子：

func main() {
	go func(callback func(string)) {
		result := longRunningTask() // 执行耗时操作
		callback(result)           // 调用回调函数处理结果
	}(func(result string) {
		fmt.Println(result) // 在这里处理返回结果
	})

	// 继续执行其他操作
}

func longRunningTask() string {
	// 执行一段耗时的操作
	return "任务执行完成"
}

在上面的例子中，我们创建了一个协程并执行了一个耗时的任务longRunningTask，然后调用了回调函数来处理返回结果。在匿名函数中，我们将result作为参数传给了回调函数，并在匿名函数中调用了回调函数来处理结果。

常见的使用场景

在Golang开发中，回调函数经常用于以下一些常见的场景。

处理I/O事件

在网络编程中，我们经常需要监听套接字的读写事件。可以使用回调函数来处理这些事件。

func main() {
	listener, err := net.Listen("tcp", ":8080")
	if err != nil {
		panic(err)
	}

	for {
		conn, err := listener.Accept()
		if err != nil {
			panic(err)
		}

		go handleConnection(conn)
	}
}

func handleConnection(conn net.Conn) {
	// 处理连接
}

在上面的例子中，我们使用回调函数handleConnection来处理每个新的TCP连接。当有新的连接进来时，通过go关键字创建一个新的协程，并将处理函数handleConnection作为参数传入，等待连接被处理。

并发任务管理

在进行大规模并发任务处理时，使用回调函数可以非常方便地管理各个任务的执行结果。

type Task struct {
	ID     int
	Result string
}

func main() {
	tasks := make([]Task, 10)
	for i := 0; i < 10;="" i++="" {="" go="" dotask(&tasks[i],="" func(task="" *task)="" {="" fmt.printf("任务="" %d="" 执行完成，结果：%s\n",="" task.id,="" task.result)="" })="" }="" 等待所有任务执行完成="" wg="" :="sync.WaitGroup{}" wg.add(10)="" for="" i="" :="0;" i="">< 10;="" i++="" {="" go="" func(task="" *task)="" {="" defer="" wg.done()="" 执行任务="" task.result="fmt.Sprintf("任务" %d="" 执行完成",="" task.id)="" }(&tasks[i])="" }="" wg.wait()="" }="" func="" dotask(task="" *task,="" callback="" func(*task))="" {="" go="" func()="" {="" 执行任务="" callback(task)="" }()="">

在上面的例子中，我们创建了一系列任务，并为每个任务分配了一个唯一的ID。然后使用回调函数来处理每个任务的执行结果。