;; async/await 语法 (async (let ([result (await (async-sleep loop 1000))]) (printf "Waited 1 second~n") result)) ;; 组合器 (async-all (list promise1 promise2 promise3)) (async-race (list fast-promise slow-promise)) (async-timeout promise 5000) ;; 取消令牌 (define cts (make-cancellation-token-source)) (define task (long-running-operation (cts 'token))) (cts 'cancel!) ; 取消操作

;; 像 JavaScript/C# 一样简洁 (async (let ([data (await (tcp-read-async client))]) (await (tcp-write-async client data))))

;; 等待所有任务 (async-all promises) ;; 竞速 (async-race promises) ;; 超时控制 (async-timeout promise 5000) ;; 取消机制 (cancellable-operation token)

(define (fetch-user-data user-id) (async (let* ([user (await (db-query "SELECT * FROM users WHERE id = ?" user-id))] [posts (await (db-query "SELECT * FROM posts WHERE user_id = ?" user-id))]) (list user posts))))

(promise-then my-promise (lambda (value) (printf "Success: ~a~n" value)) (lambda (error) (printf "Error: ~a~n" error)))

(define cts (make-cancellation-token-source)) (define task (async (when (token-cancelled? (cts 'token)) (raise (make-operation-cancelled-error))) (await (long-operation)))) ;; 在其他地方取消 (cts 'cancel!)

#!/usr/bin/env scheme-script (import (chez-async)) ;; 创建异步函数 (define (hello-async) (async (printf "Starting...~n") (await (async-sleep (uv-default-loop) 1000)) (printf "Hello, async world!~n"))) ;; 运行 (define loop (uv-default-loop)) (define p (hello-async)) (uv-run loop 'default)

(import (chez-async)) (define (fetch-data url) (async (printf "Fetching ~a...~n" url) (await (async-sleep (uv-default-loop) 1000)) (string-append "Data from " url))) (define loop (uv-default-loop)) (define p (fetch-data "http://example.com")) (promise-then p (lambda (data) (printf "Got: ~a~n" data) (uv-stop loop))) (uv-run loop 'default)

(define (parallel-fetch) (async (let ([urls '("url1" "url2" "url3")]) (let ([promises (map fetch-data urls)]) ;; 等待所有任务完成 (await (async-all promises))))))

(import (chez-async)) (define (handle-client client) (async (let loop () (let ([data (await (tcp-read-async client))]) (when (bytevector? data) (await (tcp-write-async client data)) (loop)))))) (define (start-server) (let* ([loop (uv-default-loop)] [server (uv-tcp-init loop)]) (uv-tcp-bind server "0.0.0.0" 8080) (uv-tcp-listen server 128 (lambda (srv err) (unless err (let ([client (uv-tcp-accept srv)]) (handle-client client))))) (uv-run loop 'default)))

(define (with-timeout) (async (guard (e [(timeout-error? e) (printf "Operation timed out!~n")]) (await (async-timeout (long-running-operation) 5000))))) (define (cancellable-task) (let ([cts (make-cancellation-token-source)]) ;; 5秒后自动取消 (async-sleep loop 5000) (cts 'cancel!) ;; 运行可取消任务 (async (let ([token (cts 'token)]) (await (long-operation-with-cancellation token))))))

(async body ...) ; 创建异步函数，返回 Promise (await promise) ; 等待 Promise 完成

(make-promise loop executor) ; 创建 Promise (promise-then p on-fulfilled [on-rejected]) ; 链式调用 (promise-catch p on-rejected) ; 捕获错误 (promise-finally p on-finally) ; 清理资源 (promise-resolved loop value) ; 创建已完成的 Promise (promise-rejected loop reason) ; 创建已拒绝的 Promise

(async-all promises) ; 等待全部完成 (async-race promises) ; 返回最快的 (async-any promises) ; 返回首个成功 (async-timeout promise ms) ; 添加超时 (async-sleep loop ms) ; 延迟 (async-delay loop ms thunk) ; 延迟执行 (async-catch thunk) ; 错误处理 (async-finally promise cleanup) ; 资源清理

(make-cancellation-token-source) ; 创建取消源 (cts 'token) ; 获取令牌 (cts 'cancel!) ; 请求取消 (token-cancelled? token) ; 检查是否已取消 (token-register! token callback) ; 注册取消回调

;; TCP (uv-tcp-init loop) (uv-tcp-bind tcp addr port) (uv-tcp-listen tcp backlog callback) (uv-tcp-connect tcp addr port callback) ;; UDP (uv-udp-init loop) (uv-udp-bind udp addr port) (uv-udp-send! udp data addr port callback) (uv-udp-recv-start! udp callback) ;; Stream (uv-read-start! stream callback) (uv-write! stream data callback)

(uv-fs-open path flags mode callback) (uv-fs-read fd buffer offset callback) (uv-fs-write fd buffer offset callback) (uv-fs-close fd callback) (uv-fs-stat path callback) (uv-fs-unlink path callback)