v/examples/concurrent_news_fetcher.v

// 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
}