为clojure中的每个请求分配线程

Question

我对所有这些异步/多线程lib和本地clojure功能感到迷茫。

我有一个Web服务，它调用外部API，转换它响应，然后回馈给客户端。现在是用Python编写的。我想让每个客户端在单独的线程中执行其请求，这样它们就不会等待彼此完成，或者服务器是异步的。不涉及繁重的计算，只需等待IO。

我原以为使用clojure会很容易，但是我忽略了一些东西...Aleph是异步服务器吧？然而，当我在请求处理程序中模拟一个< code>wait时，整个服务器都在等待，而不仅仅是客户端。所以我不太明白异步有什么意义？

在我的理解中，可能是错误的，异步服务器从不为IO操作阻塞？可能< code>sleep是模拟等待IO的一个不好的手段？

编辑我创建了一个哑等待服务，我从Clojure的Aleph服务器调用该服务，但请求处理仍然是顺序的

(ns aleph-t.core
 ( :require [aleph.http :as http]
            [aleph.netty :as netty]))

(defn heavy [] (Thread/sleep 10000) "hello!")

(defn handler [req]
  {:status 200
   :headers {"content-type" "text/plain"}
   :body (heavy)})
; need to wait otherwise server is closed
(defn -main [& args]
  (netty/wait-for-close (http/start-server handler {:port 8080}))
  )

Answer 1

在编写异步后端时，您需要记住，您不能使用阻塞方法调用，因为它们会阻塞您的异步工作线程，从而阻塞您的整个后端。

异步编程的基本思想是让你的工作线程主要执行真正的CPU工作，并对所有其他潜在的阻塞操作使用回调（或通道，流或流形等）。通过这种方式，异步编程可以为应用程序提供更高的吞吐量。

在您的示例中，< code >(线程/睡眠。)阻塞一个工作线程。

使用aleph for HTTP时，可以使用流形库进行异步IO。

有一些将alef与流形一起使用的示例。例如，您可以使用core.async超时来模拟长时间运行的任务，如本例所示。