mirror of
https://github.com/vlang/v.git
synced 2023-08-10 21:13:21 +03:00
Initial commit
This commit is contained in:
35
examples/concurrent_news_fetcher.v
Normal file
35
examples/concurrent_news_fetcher.v
Normal file
@@ -0,0 +1,35 @@
|
||||
// Please share your thoughts, suggestions, questions, etc here:
|
||||
// https://github.com/vlang-io/V/issues/3
|
||||
// I'm very interested in your feedback.
|
||||
import http
|
||||
import json
|
||||
import runtime
|
||||
|
||||
struct Story {
|
||||
title string
|
||||
}
|
||||
|
||||
// Fetches top HN stories in 8 coroutines
|
||||
fn main() {
|
||||
resp := http.get('https://hacker-news.firebaseio.com/v0/topstories.json')?
|
||||
ids := json.decode([]int, resp.body)?
|
||||
mut cursor := 0
|
||||
for _ in 0..8 {
|
||||
go fn() {
|
||||
for {
|
||||
lock { // Without this lock the program will not compile
|
||||
if cursor >= ids.len {
|
||||
break
|
||||
}
|
||||
id := ids[cursor]
|
||||
cursor++
|
||||
}
|
||||
url := 'https://hacker-news.firebaseio.com/v0/item/$id.json'
|
||||
resp := http.get(url)?
|
||||
story := json.decode(Story, resp.body)?
|
||||
println(story.title)
|
||||
}
|
||||
}()
|
||||
}
|
||||
runtime.wait() // Waits for all coroutines to finish
|
||||
}
|
||||
Reference in New Issue
Block a user