Início / coding / Perguntas / 79054607
Accepted
kelly
Asked: 2024-10-04 21:49:53 +0800 CST

Usando pools de threads claypoole sem pré-avaliar tudo

  • 772

Quero passar um formulário para ser avaliado para um pool de threads de destino como um futuro por meio da biblioteca claypoole em clojure.

Tentei passar o corpo de uma função para um pool de threads e esperava que esse corpo fosse avaliado em uma thread em vez de inline.

O código que tenho é parecido com este:

(defn in-thread [thread & body] (claypoole/future thread body))

Que é chamado assim:

(defonce pool (claypoole/threadpool 20))

(defn do-something [pool]
  (in-thread pool
    (Thread/sleep 5000)
    (println "foo")))

Depois de alguns testes, cheguei à conclusão de que isso bodyestá sendo avaliado quando chamo in-thread, fazendo com que minha solução inteira não faça nada significativo. Sei que há algum tipo de conceito básico que estou esquecendo, mas toda vez que tento olhar para macros minha cabeça começa a girar.

Como eu transformaria a in-threadfunção em uma macro que passa o corpo para o pool de threads para execução, em vez do resultado?

clojure

1 respostas

  1. Best Answer

    Quando você usa uma função - isto é, uma construção criada com defn/ fn- todos os seus argumentos serão avaliados antes que a função em si seja chamada. Então, no seu caso, a in-threadfunção é chamada com os resultados de (Thread/sleep ...)e (println ...), e ambos são nil.

    Para passar formulários sem realmente avaliá-los, você precisa citá-los e usá-los evalmais tarde ou usar uma macro, que é uma abordagem muito mais comum.

    No seu caso, seria suficiente substituir a definição de in-threadpor:

    (defmacro in-thread [thread & body]
  `(claypoole/future ~thread ~@body))

    No entanto, observe que ele se torna apenas um wrapper claypoole/futureque não faz nada por si só. E claypoole/futureele próprio já é uma macro - você nem precisa de in-thread! Tudo o que você precisa já está implementado por claypoole/future, então você pode usar apenas isto:

    (defonce pool (claypoole/threadpool 20))

(defn do-something [pool]
  (claypoole/future pool
    (Thread/sleep 5000)
    (println "foo")))
    • 0

relate perguntas