Golang中如何解决无法将信息传递到channel的问题

Golang中如何解决无法将信息传递到channel的问题 代码链接

这是我编写的用于解析文档并查找信息缺失行的代码链接。当我将信息移动到msgs通道时，它无法正常工作。请告诉我如何修正这个问题。

4 回复

非常感谢，这个方法完美奏效！

更多关于Golang中如何解决无法将信息传递到channel的问题的实战系列教程也可以访问 https://www.itying.com/category-94-b0.html


请描述任务的实际行为、预期行为以及您正在尝试做什么。没有.csv文件的样本很难进行测试。

我对你的代码进行了一些重构，其中存在几个问题。但我只指出导致你提到问题的两个关键点。

你调用了两个goroutine：

wg.Add(1)## 改为 wg.Add(2) 以等待两个goroutine
go consume(whichones)
go produce("PeopleEx1.csv", &wg)

其次，当生产者完成时，你也需要停止消费者。 （请查看 https://golang.org/pkg/context/） 为此，你可以调用 close(msgs) 通道，并按以下方式修改接收通道：

select {
		case a, ok := <-msgs:
			{
				if !ok {
					fmt.Println("INFO: exiting from consume")
					return
				}
				d := missing(a)
				if d == false {
					whichones = append(whichones, counter)
				}
			}}

这是重构后的代码： https://play.golang.org/p/-H6vDiMne3D

在您提供的代码中，问题出现在goroutine执行完毕前主程序已经退出，导致通道中的数据没有机会被处理。以下是修正后的代码：

package main

import (
	"fmt"
	"strings"
	"sync"
)

func main() {
	lines := []string{
		"line 1: complete",
		"line 2: missing data",
		"line 3: complete", 
		"line 4: missing data",
		"line 5: complete",
	}

	msgs := make(chan string)
	var wg sync.WaitGroup

	// 启动goroutine处理文档
	wg.Add(1)
	go func() {
		defer wg.Done()
		defer close(msgs) // 处理完成后关闭通道
		
		for i, line := range lines {
			if !strings.Contains(line, "complete") {
				msg := fmt.Sprintf("Line %d is missing information: %s", i+1, line)
				msgs <- msg
			}
		}
	}()

	// 启动单独的goroutine来接收消息
	go func() {
		wg.Wait()
	}()

	// 主程序接收并处理所有消息
	for msg := range msgs {
		fmt.Println(msg)
	}
}

关键修改点：

  1. 使用WaitGroup确保goroutine完成：添加了sync.WaitGroup来等待处理goroutine完成
  2. 正确关闭通道：在处理完成后关闭msgs通道，这样range循环才能正常结束
  3. 分离发送和接收逻辑：确保接收循环在主goroutine中运行

另一个更简洁的解决方案是使用缓冲通道：

package main

import (
	"fmt"
	"strings"
)

func main() {
	lines := []string{
		"line 1: complete",
		"line 2: missing data", 
		"line 3: complete",
		"line 4: missing data",
		"line 5: complete",
	}

	msgs := make(chan string, len(lines)) // 使用缓冲通道

	// 发送所有消息到通道
	for i, line := range lines {
		if !strings.Contains(line, "complete") {
			msg := fmt.Sprintf("Line %d is missing information: %s", i+1, line)
			msgs <- msg
		}
	}
	close(msgs) // 关闭通道

	// 接收并打印所有消息
	for msg := range msgs {
		fmt.Println(msg)
	}
}

这个版本不需要goroutine，直接使用缓冲通道来避免阻塞问题。输出结果将是：

Line 2 is missing information: line 2: missing data
Line 4 is missing information: line 4: missing data
回到顶部