php小編香蕉在這裡與大家分享一個有趣的技巧-「暫停一秒鐘後繼續讀取資料」。在程式設計中,有時候我們需要等待一段時間後再繼續執行後續的操作,而這個技巧可以幫助我們實現這個目標。無論是用於網路請求的延時操作,還是為了避免某些耗時的操作影響程式的執行效率,這個技巧都能發揮重要的作用。下面,我們將詳細介紹如何在php中實現這個功能。
我正在使用curl從端點獲取資料並將其傳輸到程式中。程式的main函數讀取資料是這樣的
reader := bufio.NewReader(os.Stdin) var buf bytes.Buffer line, err := reader.ReadString(`\n`) for { if err != nil{ buf.WriteString(line) break } buf.WriteString(line) } var data Memstats err = json.Unmarshal(buf.Bytes(), &data)
到這裡為止一切正常。然而,我的最終目標是像這樣重複捲曲端點一段時間,以便程式讀取以 N 時間間隔到達的 N 個 JSON blob。
for i in {1..10}; do curl localhost:6000/debug/vars | ./myprogram; sleep 1; done
每次捲曲到端點後都會到達相同結構的資料。因此,我必須將數據讀取代碼移至函數readStdIn
中,我將重複調用該函數,直到curl 停止發送數據,並且每次我的程式接收到json 數據時,我都會將其解組到結構中並將其添加到切片中。為了重複呼叫 readStdIn,我使用了 for 循環,為了讀取 readStdIn 中的數據,我也使用了 for 迴圈。 readStdIn
函數永遠無法完成。為什麼不呢?
主要功能
for{ reader := bufio.NewReader(os.Stdin) h.readStdIn(reader) time.Sleep(1 * time.Second) var err error //check to see if curl sent more data, if not I break out of main function and continue on with program and hopefully an array full of Memstats newbytes, err := reader.ReadByte() if err != nil{ break } }
readStdIn函數
#func (rt *Graph)readStdIn(reader *bufio.Reader){ var buf bytes.Buffer line, err := reader.ReadString('\n') for { if err != nil{ if err == io.EOF{ buf.WriteString(line) break }else{ fmt.Println(err.Error()) os.Exit(1) } } } buf.WriteString(line) } var data Memstats err = json.Marshal(buf.Bytes(), &data) rt.Memstats = append(rt.Memstats, &record) }
#您也可以透過自訂函數或更改 bash 腳本來使用掃描器。但我相信兩者都比下面的程式碼更複雜。
<code>package main import ( "encoding/json" "errors" "fmt" "io" "os" ) func main() { fmt.Println("Start") decoder := json.NewDecoder(os.Stdin) for { var u User err := decoder.Decode(&u) if errors.Is(err, io.EOF) { fmt.Println("End") break } if err != nil { fmt.Println("Can not decode into json", err) continue } fmt.Println(u) } } type User struct { UserId int `json:"userId"` Id int `json:"id"` Title string `json:"title"` } </code>
<code>function repeatedCurl() { for i in $(seq 1 3); do # sleep 1 # optional you can emit curl -s "https://jsonplaceholder.typicode.com/posts/$i" done } repeatedCurl | ./foo </code>
<code>package main import ( "bufio" "fmt" "os" ) func main() { fmt.Println("Start") scanner := bufio.NewScanner(bufio.NewReader(os.Stdin)) for scanner.Scan() { fmt.Println(scanner.Text()) } fmt.Println("End") } </code>
它適用於建立新的程式實例(如您的範例)和正常的管道使用。
<code>function repeatedDateEcho() { while sleep 1; do echo "$(date)" done } repeatedDateEcho | ./myprogram </code>
輸出:
Start Thu Jan 18 22:59:31 +03 2024 Thu Jan 18 22:59:32 +03 2024 Thu Jan 18 22:59:33 +03 2024 Thu Jan 18 22:59:34 +03 2024
while 睡 1;做 echo "$(date)" | ./我的程式;完成
輸出:
Start Thu Jan 18 22:58:46 +03 2024 End Start Thu Jan 18 22:58:47 +03 2024 End
以上是暫停一秒鐘後繼續讀取數據的詳細內容。更多資訊請關注PHP中文網其他相關文章!