在 Java、Python、JavaScript 和 Go 中拥抱异步

ExecutorService executor = Executors.newFixedThreadPool(10);
for (String url : urls) {
    executor.submit(() -> {
        // Fetch data from the URL and process it
    });
}
executor.shutdown();
executor.awaitTermination(Long.MAX_VALUE, TimeUnit.MILLISECONDS);

import aiohttp
import asyncio

async def fetch(url):
    async with aiohttp.ClientSession() as session:
        async with session.get(url) as response:
            return await response.text()

async def main():
    urls = [...]  # List of URLs
    tasks = [fetch(url) for url in urls]
    responses = await asyncio.gather(*tasks)

asyncio.run(main())

const axios = require("axios");

async function fetchData(urls) {
    const promises = urls.map(url => axios.get(url));
    const results = await Promise.all(promises);
    // Process the results
}

const urls = [...]  // List of URLs
fetchData(urls);

package main

import (
    "fmt"
    "net/http"
    "io/ioutil"
)

func processSource(url string, ch chan<- string) {
    resp, err := http.Get(url)
    if err != nil {
        ch <- fmt.Sprintf("Error fetching data from %s: %v", url, err)
        return
    }
    defer resp.Body.Close()
    body, err := ioutil.ReadAll(resp.Body)
    // Process the fetched data
    ch <- fmt.Sprintf("Processed data from %s", url)
}

func main() {
    sources := [...]  // List of data sources
    ch := make(chan string, len(sources))

    for _, url := range sources {
        go processSource(url, ch)
    }

    for range sources {
        fmt.Println(<-ch)
    }
}