我將運(yùn)行一個(gè)將輸出推送到文件系統(tǒng)中的 FIFO 文件的命令。在 bash 中，我可以寫timeout 3000 cat server_fifo>server.url等到 fifo 被推送一個(gè)輸出，或者它達(dá)到 3000 超時(shí)。我想知道我們?nèi)绾卧?golang 中做到這一點(diǎn)，即一直等待 fifo 文件的輸出，并為此等待設(shè)置超時(shí)。根據(jù) matishsiao 的 gist 腳本，我知道我們可以做到 file, err := os.OpenFile(urlFileName, os.O_CREATE, os.ModeNamedPipe) if err != nil { log.Fatal("Open named pipe file error:", err) } reader := bufio.NewReader(file) for { _, err := reader.ReadBytes('\n') if err == nil { fmt.Println("cockroach server started") break } }但是在這種情況下，如何在 for 循環(huán)中添加超時(shí)？
1 回答
慕容3067478
TA貢獻(xiàn)1773條經(jīng)驗(yàn) 獲得超3個(gè)贊
這是您可以使用的簡(jiǎn)單樣板：
finished := make(chan bool)
go func() {
/*
* Place your code here
*/
finished <- true
}()
select {
case <-time.After(timeout):
fmt.Println("Timed out")
case <-finished:
fmt.Println("Successfully executed")
}
分配time.Second*3或任何Duration變量timeout。
編輯：添加帶有回調(diào)的示例函數(shù)：
func timeoutMyFunc(timeout time.Duration, myFunc func()) bool {
finished := make(chan bool)
go func() {
myFunc()
finished <- true
}()
select {
case <-time.After(timeout):
return false
case <-finished:
return true
}
}
func main() {
success := timeoutMyFunc(3*time.Second, func() {
/*
* Place your code here
*/
})
}這是您可以使用的簡(jiǎn)單樣板：
finished := make(chan bool)
go func() {
/*
* Place your code here
*/
finished <- true
}()
select {
case <-time.After(timeout):
fmt.Println("Timed out")
case <-finished:
fmt.Println("Successfully executed")
}
分配time.Second*3或任何Duration變量timeout。
編輯：添加帶有回調(diào)的示例函數(shù)：
func timeoutMyFunc(timeout time.Duration, myFunc func()) bool {
finished := make(chan bool)
go func() {
myFunc()
finished <- true
}()
select {
case <-time.After(timeout):
return false
case <-finished:
return true
}
}
func main() {
success := timeoutMyFunc(3*time.Second, func() {
/*
* Place your code here
*/
})
}
- 1 回答
- 0 關(guān)注
- 93 瀏覽
添加回答
舉報(bào)
0/150
提交
取消