- 23
- 0
问题描述
两个goroutine,一个goroutine中做键盘的输入,另一个goroutine做其它数据处理。 运行后,如果我不输入数据,另一个goroutine也停止运行了。也没调度。我希望即使我不输入数据,也不要影响另一个goroutine。
问题出现的环境背景及自己尝试过哪些方法
相关代码
// 请把代码文本粘贴到下方(请勿用图片代替代码)
package main
import (
"fmt"
"os"
"bufio"
"math/rand"
)
func main() {
msgChan := make(chan string)
roundChan := make(chan int)
sleepChan := make(chan bool)
go input(msgChan)
go roundNum(roundChan)
go Scheduler(msgChan,roundChan)
<-sleepChan
}
func Scheduler(msgChan chan string,roundChan chan int) {
var(
msg string
round int
)
for{
select {
case msg = <-msgChan:
fmt.Println("msg:",msg)
case round = <- roundChan:
fmt.Println(round)
}
}
}
func roundNum(roundChan chan int) {
roundChan <- rand.Int()
}
func input(msgChan chan string) {
var(
msg string
err error
)
for{
fmt.Println("请输入要回复的消息:")
if msg,err = bufio.NewReader(os.Stdin).ReadString('\n');err!=nil{
return
}
msgChan<-msg
}
}
你期待的结果是什么?实际看到的错误信息又是什么?
期待: 可以随时输入键盘数据,如果我输入键盘数据两个goroutine都正常运行。如果我不输入键盘数据,也不要影响另一个goroutine的执行。
0
打赏
收藏
点击回答
您的回答被采纳后将获得:提问者悬赏的 10 元积分
- 共 0 条
- 全部回答
-
╰☆╮倾城‘ヅ绝舞 普通会员 1楼
在Go语言中,bufio.NewReader(os.Stdin)默认是阻塞的,因为它在读取标准输入流时会阻塞。如果你想解决这个问题,你可以使用io.Copy和io.LimitReader函数。
以下是一个示例:
```go package main
import ( "bytes" "fmt" "io" "io/ioutil" "os" "strings" )
func main() { // 创建一个标准输入流 var in io.Reader // 创建一个缓冲区来保存输入流的原始内容 var buffer bytes.Buffer
// 使用io.Copy复制输入流的内容到缓冲区 err := io.Copy(&buffer, &in) if err != nil { fmt.Println(err) return } // 使用io.LimitReader限制读取的最大次数,以便在读取过程中不断更新缓冲区的内容 max := 1000000 for { // 读取最多1000000个字节 if buffer.Len() >= max { break } } // 将缓冲区的内容写入文件 err = ioutil.WriteFile("output.txt", buffer.Bytes(), 0644) if err != nil { fmt.Println(err) return } fmt.Println("文件已创建")} ```
在这个示例中,我们首先创建了一个标准输入流,然后使用io.Copy复制输入流的内容到缓冲区。然后,我们使用io.LimitReader限制读取的最大次数,以便在读取过程中不断更新缓冲区的内容。最后,我们将缓冲区的内容写入文件。
这样,即使在读取过程中,goroutine调度也不会阻塞。
更多回答
网站公告
- 扫一扫访问手机版
回答动态

- 神奇的四哥:发布了悬赏问题阿里云幻兽帕鲁服务器更新之后。服务器里面有部分玩家要重新创建角色是怎么回事啊?预计能赚取 0积分收益

- 神奇的四哥:发布了悬赏问题函数计算不同地域的是不能用内网吧?预计能赚取 0积分收益

- 神奇的四哥:发布了悬赏问题ARMS可以创建多个应用嘛?预计能赚取 0积分收益

- 神奇的四哥:发布了悬赏问题在ARMS如何申请加入公测呀?预计能赚取 0积分收益

- 神奇的四哥:发布了悬赏问题前端小程序接入这个arms具体是如何接入监控的,这个init方法在哪里进行添加?预计能赚取 0积分收益

- 神奇的四哥:发布了悬赏问题阿里云幻兽帕鲁服务器刚到期,是不是就不能再导出存档了呢?预计能赚取 0积分收益

- 神奇的四哥:发布了悬赏问题阿里云幻兽帕鲁服务器的游戏版本不兼容 尝试更新怎么解决?预计能赚取 0积分收益

- 神奇的四哥:发布了悬赏问题阿里云幻兽帕鲁服务器服务器升级以后 就链接不上了,怎么办?预计能赚取 0积分收益

- 神奇的四哥:发布了悬赏问题阿里云幻兽帕鲁服务器转移以后服务器进不去了,怎么解决?预计能赚取 0积分收益

- 神奇的四哥:发布了悬赏问题阿里云幻兽帕鲁服务器修改参数后游戏进入不了,是什么情况?预计能赚取 0积分收益
- 回到顶部
- 回到顶部
