mirror of
https://github.com/gopl-zh/gopl-zh.github.com.git
synced 2024-11-28 09:09:07 +00:00
ch1-06 review
This commit is contained in:
parent
e5ae056524
commit
cc8f40eaca
@ -1,6 +1,6 @@
|
|||||||
## 1.6 併發穫取多個URL
|
## 1.6. 併發穫取多個URL
|
||||||
|
|
||||||
Go語言最有意思併且最新奇的特性就是其對併發編程的支持了。併發編程是一個大話題,在第八章和第九章中會講到。這里我們隻淺嚐輒止地來體驗一下Go語言里的goroutine和channel。
|
Go語言最有意思併且最新奇的特性就是其對併發編程的支持了。併發編程是一個大話題,在第八章和第九章中會專門講到。這里我們隻淺嚐輒止地來體驗一下Go語言里的goroutine和channel。
|
||||||
|
|
||||||
下面的例子fetchall,和上面的fetch程序所要做的工作是一致的,但是這個fetchall的特别之處在於它會同時去穫取所有的URL,所以這個程序的穫取時間不會超過執行時間最長的那一個任務,而不會像前面的fetch程序一樣,執行時間是所有任務執行時間之和。這次的fetchall程序隻會打印穫取的內容大小和經過的時間,不會像上面那樣打印齣穫取的內容。
|
下面的例子fetchall,和上面的fetch程序所要做的工作是一致的,但是這個fetchall的特别之處在於它會同時去穫取所有的URL,所以這個程序的穫取時間不會超過執行時間最長的那一個任務,而不會像前面的fetch程序一樣,執行時間是所有任務執行時間之和。這次的fetchall程序隻會打印穫取的內容大小和經過的時間,不會像上面那樣打印齣穫取的內容。
|
||||||
|
|
||||||
@ -10,47 +10,47 @@ gopl.io/ch1/fetchall
|
|||||||
package main
|
package main
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"fmt"
|
"fmt"
|
||||||
"io"
|
"io"
|
||||||
"io/ioutil"
|
"io/ioutil"
|
||||||
"net/http"
|
"net/http"
|
||||||
"os"
|
"os"
|
||||||
"time"
|
"time"
|
||||||
)
|
)
|
||||||
|
|
||||||
func main() {
|
func main() {
|
||||||
start := time.Now()
|
start := time.Now()
|
||||||
ch := make(chan string)
|
ch := make(chan string)
|
||||||
for _, url := range os.Args[1:] {
|
for _, url := range os.Args[1:] {
|
||||||
go fetch(url, ch) // start a goroutine
|
go fetch(url, ch) // start a goroutine
|
||||||
}
|
}
|
||||||
for range os.Args[1:] {
|
for range os.Args[1:] {
|
||||||
fmt.Println(<-ch) // receive from channel ch
|
fmt.Println(<-ch) // receive from channel ch
|
||||||
}
|
}
|
||||||
fmt.Printf("%.2fs elapsed\n", time.Since(start).Seconds())
|
fmt.Printf("%.2fs elapsed\n", time.Since(start).Seconds())
|
||||||
}
|
}
|
||||||
|
|
||||||
func fetch(url string, ch chan<- string) {
|
func fetch(url string, ch chan<- string) {
|
||||||
start := time.Now()
|
start := time.Now()
|
||||||
resp, err := http.Get(url)
|
resp, err := http.Get(url)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
ch <- fmt.Sprint(err) // send to channel ch
|
ch <- fmt.Sprint(err) // send to channel ch
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
nbytes, err := io.Copy(ioutil.Discard, resp.Body)
|
nbytes, err := io.Copy(ioutil.Discard, resp.Body)
|
||||||
resp.Body.Close() // don't leak resources
|
resp.Body.Close() // don't leak resources
|
||||||
if err != nil {
|
if err != nil {
|
||||||
ch <- fmt.Sprintf("while reading %s: %v", url, err)
|
ch <- fmt.Sprintf("while reading %s: %v", url, err)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
secs := time.Since(start).Seconds()
|
secs := time.Since(start).Seconds()
|
||||||
ch <- fmt.Sprintf("%.2fs %7d %s", secs, nbytes, url)
|
ch <- fmt.Sprintf("%.2fs %7d %s", secs, nbytes, url)
|
||||||
}
|
}
|
||||||
|
|
||||||
```
|
```
|
||||||
|
|
||||||
下面是一個使用的例子
|
下面是一個使用的例子
|
||||||
|
|
||||||
```bash
|
```
|
||||||
$ go build gopl.io/ch1/fetchall
|
$ go build gopl.io/ch1/fetchall
|
||||||
$ ./fetchall https://golang.org http://gopl.io https://godoc.org
|
$ ./fetchall https://golang.org http://gopl.io https://godoc.org
|
||||||
0.14s 6852 https://godoc.org
|
0.14s 6852 https://godoc.org
|
||||||
@ -58,10 +58,11 @@ $ ./fetchall https://golang.org http://gopl.io https://godoc.org
|
|||||||
0.48s 2475 http://gopl.io
|
0.48s 2475 http://gopl.io
|
||||||
0.48s elapsed
|
0.48s elapsed
|
||||||
```
|
```
|
||||||
goroutine是一種函數的併行執行方式,而channel是用來在goroutine之間進行參數傳遞。main函數卽運行在一個goroutine中,而go function則表示創建一個新的goroutine,併讓這個函數去這個新的goroutine里執行。
|
|
||||||
|
|
||||||
main函數中用make函數創建了一個傳遞string類型參數的channel,對每一個命令行參數,我們都用go這個關鍵字來創建一個goroutine,併且讓函數在這個goroutine異步執行http.Get方法。這個程序里的io.Copy會把響應的Body內容拷貝到ioutil.Discard輸齣流中,因爲我們需要這個方法返迴的字節數,但是又不想要其內容。每當請求返迴內容時,fetch函數都會往ch這個channel里寫入一個字符串,由main函數里的第二個for循環來處理併打印channel里的這個字符串。
|
goroutine是一種函數的併發執行方式,而channel是用來在goroutine之間進行參數傳遞。main函數也是運行在一個goroutine中,而go function則表示創建一個新的goroutine,併在這個這個新的goroutine里執行這個函數。
|
||||||
|
|
||||||
|
main函數中用make函數創建了一個傳遞string類型參數的channel,對每一個命令行參數,我們都用go這個關鍵字來創建一個goroutine,併且讓函數在這個goroutine異步執行http.Get方法。這個程序里的io.Copy會把響應的Body內容拷貝到ioutil.Discard輸齣流中(譯註:這是一個垃圾桶,可以向里面寫一些不需要的數據),因爲我們需要這個方法返迴的字節數,但是又不想要其內容。每當請求返迴內容時,fetch函數都會往ch這個channel里寫入一個字符串,由main函數里的第二個for循環來處理併打印channel里的這個字符串。
|
||||||
|
|
||||||
當一個goroutine嚐試在一個channel上做send或者receive操作時,這個goroutine會阻塞在調用處,直到另一個goroutine往這個channel里寫入、或者接收了值,這樣兩個goroutine纔會繼續執行操作channel完成之後的邏輯。在這個例子中,每一個fetch函數在執行時都會往channel里發送一個值(ch <- expression),主函數接收這些值(<-ch)。這個程序中我們用main函數來所有fetch函數傳迴的字符串,可以避免在goroutine異步執行時同時結束。
|
當一個goroutine嚐試在一個channel上做send或者receive操作時,這個goroutine會阻塞在調用處,直到另一個goroutine往這個channel里寫入、或者接收了值,這樣兩個goroutine纔會繼續執行操作channel完成之後的邏輯。在這個例子中,每一個fetch函數在執行時都會往channel里發送一個值(ch <- expression),主函數接收這些值(<-ch)。這個程序中我們用main函數來所有fetch函數傳迴的字符串,可以避免在goroutine異步執行時同時結束。
|
||||||
|
|
||||||
Exercise 1.10: 找一個數據量比較大的網站,用本小節中的程序調研網站的緩存策略,對每個URL執行兩遍請求,査看兩次時間是否有較大的差别,併且每次穫取到的響應內容是否一致,脩改本節中的程序,將響應結果輸齣,以便於進行對比。
|
**練習 1.10:** 找一個數據量比較大的網站,用本小節中的程序調研網站的緩存策略,對每個URL執行兩遍請求,査看兩次時間是否有較大的差别,併且每次穫取到的響應內容是否一致,脩改本節中的程序,將響應結果輸齣,以便於進行對比。
|
||||||
|
Loading…
Reference in New Issue
Block a user