Синхронизация агентов и потоков в Clojure

Я должен переписать этот код с помощью агентов, так что результат x равен 0 (это означает, что каждый поток выполняется один за другим). Но у меня проблемы, потому что у меня недостаточно знаний об использовании агентов. Оригинальный код:

(def x 0)
(let [t1 (Thread. #(dotimes [_ 10000] (def x (inc x))))
      t2 (Thread. #(dotimes [_ 10000] (def x (dec x))))]
  (.start t1)
  (.start t2)
  (.join t1)
  (.join t2)
  (println x))

Когда я хочу использовать агент с ожиданием (имя_агента), чтобы каждый поток выполнялся отдельно, это не работает, результат всегда отличен от нуля. Пожалуйста, какие-либо предложения по этому поводу?

multithreading join concurrency clojure

08.04.2019 03:00

Стоит ли изучать PHP в 2023-2024 годах?

Привет всем, сегодня я хочу высказать свои соображения по поводу вопроса, который я уже много раз получал в своем сообществе: "Стоит ли изучать PHP в...

Поведение ключевого слова "this" в стрелочной функции в сравнении с нормальной функцией

В JavaScript одним из самых запутанных понятий является поведение ключевого слова "this" в стрелочной и обычной функциях.

Приемы CSS-макетирования - floats и Flexbox

Здравствуйте, друзья-студенты! Готовы совершенствовать свои навыки веб-дизайна? Сегодня в нашем путешествии мы рассмотрим приемы CSS-верстки - в...

Тестирование функциональных ngrx-эффектов в Angular 16 с помощью Jest

В системе управления состояниями ngrx, совместимой с Angular 16, появились функциональные эффекты. Это здорово и делает код определенно легче для...

Концепция локализации и ее применение в приложениях React ⚡️

Локализация - это процесс адаптации приложения к различным языкам и культурным требованиям. Это позволяет пользователям получить опыт, соответствующий...

Пользовательский скаляр GraphQL

Листовые узлы системы типов GraphQL называются скалярами. Достигнув скалярного типа, невозможно спуститься дальше по иерархии типов. Скалярный тип...

Перейти к ответу Данный вопрос помечен как решенный

Ответы 1

Ответ принят как подходящий

Я попробовал это, и он печатает 0, как и ожидалось:

(ns agent-demo.core
  (:gen-class))

(def counter
  (agent 0))

(defn -main [& args]
  (let [t1 (Thread. #(dotimes [_ 10000]
                       (send counter inc)))
        t2 (Thread. #(dotimes [_ 10000]
                       (send counter dec)))]
    (.start t1)
    (.start t2)
    (.join t1)
    (.join t2)
    (await counter)
    (println @counter)
    (shutdown-agents)))

Спасибо, мой друг, я застрял в этом вопросе. :D

— 08.04.2019 09:45

08.04.2019 07:38