我有一個文件abc.txt，其中包含打印兩次的字母表，并用換行符分隔abcdefghijklmopqrstuvwxyz
abcdefghijklmopqrstuvwxyz我想創(chuàng)建一個可以同時解析行的解析器。例如，每行一個 goroutine。我當前嘗試執(zhí)行此操作的流程是：創(chuàng)建一個通道來接收文本行為每行創(chuàng)建一個新的掃描儀將掃描儀和通道傳遞給 goroutine主進程中的處理結果然而，只有一臺掃描儀返回有用的輸出。我想做的代碼是這樣的：func main() { file, err := os.Open("./strangeness/abc.txt") if err != nil { log.Panic(err) } defer file.Close() inChan := make(chan string) for i := 0; i < 2; i++ { var scanner scanner.Scanner file.Seek(27, 0) scanner.Init(file) go parseLine(fmt.Sprintf("Scanner %v:", i), &scanner, inChan) } for msg := range inChan { fmt.Println(msg) }}func parseLine(name string, scanner *scanner.Scanner, out chan string) { for i := 0; i < 26; i++ { out <- fmt.Sprintf("%s %c", name, scanner.Next()) }}我想我可能對 go 的text/scanner工作原理或文件的一般工作原理有一些誤解，但我無法追蹤錯誤的實際來源。
1 回答
楊__羊羊
TA貢獻1943條經(jīng)驗 獲得超7個贊
該問題似乎是由于 2 個文件掃描儀同時移動頭部所致。
可以通過創(chuàng)建 2 個文件句柄（每個句柄都有自己的掃描儀）來實現(xiàn)所需的結果。以下對我有用
package main
import (
"fmt"
"log"
"os"
"text/scanner"
"time"
)
func main(){
var file [2]*os.File
var err error
file[0], err = os.Open("./abc.txt")
file[1], err = os.Open("./abc.txt")
if err != nil {
log.Panic(err)
}
defer file[0].Close()
defer file[1].Close()
var scanner [2]scanner.Scanner
inChan := make(chan string)
for i := 0; i < 2; i++ {
var n int64 = (int64)(i) * 26
file[i].Seek(n, 0)
scanner[i].Init(file[i])
fmt.Println(scanner[0].Pos)
go parseLine(fmt.Sprintf("Scanner %v:", i), &scanner[i], inChan)
}
for msg := range inChan {
fmt.Println(msg)
}
}
func parseLine(name string, scanner *scanner.Scanner, out chan string) {
for i := 0; i < 26; i++ {
out <- fmt.Sprintf("%s %c", name, scanner.Next())
}
time.Sleep(time.Second * 10)
close(out)
}
- 1 回答
- 0 關注
- 133 瀏覽
添加回答
舉報
0/150
提交
取消