點擊參加51CTO網(wǎng)站內(nèi)容調(diào)查問卷
作者丨Andrei Tetka
策劃丨千山
作為一名擁有多年Java經(jīng)驗的軟件開發(fā)人員，當我最近切換到Python進行一個新項目時，我發(fā)現(xiàn)自己很感興趣。這種轉(zhuǎn)變促使我探索各種語言的異步編程世界，包括Java，Python，JavaScript和Golang。本文是我對這些語言的探索和個人經(jīng)驗的結(jié)果，旨在提供對異步編程技術(shù)和示例的見解。
1、Java中的異步編程
當我第一次開始用Java編程時，我很快就熟悉了線程的概念。隨著時間的推移，我發(fā)現(xiàn)Executor框架和CompletableFuture類提供了更強大、更靈活的方法來處理異步操作。
例如，我使用Executor框架構(gòu)建了一個網(wǎng)絡(luò)抓取工具，可以同時從多個網(wǎng)站獲取數(shù)據(jù)。通過使用固定線程池，我能夠限制同時連接的數(shù)量，同時有效地管理資源：
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);2、Python中的異步編程
切換到Python后，我最初受到異步編程的不同方法的挑戰(zhàn)。但是，在了解了asyncio庫和async/await語法后，我發(fā)現(xiàn)它是一個強大而優(yōu)雅的解決方案。
我曾經(jīng)實現(xiàn)過一個基于Python的微服務(wù)，需要進行多次API調(diào)用。通過利用asyncio和async/await，我能夠并發(fā)執(zhí)行這些調(diào)用，并顯著縮短整體響應(yīng)時間：
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())3、JavaScript中的異步編程
在使用JavaScript時，我很欣賞它對異步編程的固有支持。因此，我在各種Web應(yīng)用程序中廣泛使用了回調(diào)、承諾和異步/等待。
例如，我曾經(jīng)構(gòu)建過一個Node.js應(yīng)用程序，該應(yīng)用程序需要來自多個RESTful API 的數(shù)據(jù)。通過使用promise和async/await，我能夠簡化代碼并更優(yōu)雅地處理錯誤：
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);4、Golang中的異步編程
在我探索Golang的過程中，我對它對并發(fā)和異步編程的原生支持著迷，這要歸功于goroutines和channels。
例如，在處理一個需要實時處理來自多個來源的數(shù)據(jù)的項目時，我利用goroutines和通道來有效地管理資源并同步數(shù)據(jù)流：
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)
}
}5、結(jié)論
異步編程是現(xiàn)代應(yīng)用程序開發(fā)的一個重要方面，深入了解其跨各種語言的實現(xiàn)是非常寶貴的。我在Java、Python、JavaScript和Golang方面的經(jīng)驗告訴我，每種語言都有其獨特而強大的功能來管理異步任務(wù)。通過分享這些經(jīng)驗和示例，我的目標是鼓勵其他人在他們的項目中采用異步性，最終成就更高效和響應(yīng)更快的應(yīng)用程序。
原文鏈接：https://dzone.com/articles/embracing-asynchrony-in-java-python-javascript-and
