golang协成里写回调

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。然后使用回调函数来处理每个任务的执行结果。

总结

回调函数是Golang协程编程中非常重要的一部分，它能够实现异步编程，处理耗时操作的返回结果或错误信息。在实际开发中，回调函数常常用于处理I/O事件、并发任务管理等场景。通过合理的使用回调函数，我们可以更加高效地利用协程的特性，提高程序的并发能力。