Типы изменяемых хранилищ Clojure

Похоже, вы действительно получаете Clojure! Молодец :)

У переменных есть «корневая привязка», видимая во всех потоках, и каждый отдельный поток может изменить значение, которое он видит, не затрагивая другие потоки. Если я правильно понимаю, var не может существовать только в одном потоке без корневой привязки, которая видна всем, и она не может быть «восстановлена», пока она не будет определена с помощью (def...) в первый раз.

Рефы фиксируются в конце транзакции (dosync...), которая заключает в себе изменения, но только тогда, когда транзакция смогла завершиться в согласованном состоянии.

Я думаю, что ваш вывод об атомах неверен:

Атомы похожи на Vars, но с безопасностью совместного использования потоков, которая блокируется до тех пор, пока значение не изменится.

Атомы изменяются с помощью swap! или низкоуровневые с помощью compare-and-set!. Это никогда ничего не блокирует. swap! работает как транзакция только с одной ссылкой:

1. старое значение берется из атома и сохраняется локально в потоке
2. функция применяется к старому значению для генерации нового значения
3. если это удается, вызывается функция сравнения и установки со старым и новым значением; только если значение атома не было изменено каким-либо другим потоком (по-прежнему равно старому значению), записывается новое значение, в противном случае операция перезапускается с (1) до тех пор, пока в конечном итоге не завершится успешно.

Я нашел две проблемы с вашим вопросом.

Ты говоришь:

Если к агенту обращаются во время выполнения действия, значение не возвращается до тех пор, пока действие не завершится.

http://clojure.org/agents говорит:

состояние агента всегда сразу доступно для чтения любым потоком

т.е. вам никогда не придется ждать, чтобы получить значение агента (я предполагаю, что значение, измененное действием, передается через прокси и изменяется атомарно).

Код для deref-метода Agent выглядит так (версия SVN 1382):

public Object deref() throws Exception{
    if(errors != null)
    {
        throw new Exception("Agent has errors", (Exception) RT.first(errors));
    }
return state;

}

Никакой блокировки не происходит.

Кроме того, я не понимаю, что вы имеете в виду (в разделе Ref) под

Транзакции фиксируются при вызовах deref

Транзакции фиксируются, когда все действия блока dosync завершены, исключений не возникло и ничто не привело к повторной попытке транзакции. Я думаю, что deref не имеет к этому никакого отношения, но, возможно, я неправильно понял вашу мысль.

Мартин прав, когда говорит, что операция Atom перезапускается с 1. до тех пор, пока в конечном итоге не добьется успеха. Это также называется ожиданием вращения. Несмотря на то, что на самом деле блокируется блокировка, поток, выполнивший операцию, блокируется до тех пор, пока операция не завершится успешно, поэтому это блокирующая операция, а не асинхронная операция.

Также о фьючерсах: в Clojure 1.1 добавлены абстракции для промисов и фьючерсов. Обещание — это конструкция синхронизации, которую можно использовать для доставки значения из одного потока в другой. Пока значение не будет доставлено, любая попытка разыменования промиса будет заблокирована.

(def a-promise (promise))
(deliver a-promise :fred)

Фьючерсы представляют собой асинхронные вычисления. Это способ заставить код выполняться в другом потоке и получать результат.

(def f (future (some-sexp)))
(deref f) ; blocks the thread that derefs f until value is available

Вары не всегда имеют корневую привязку. Законно создавать var без привязки, используя

(def x)

or

(declare x)

Попытка оценить x до того, как он получит значение, приведет к

Var user/x is unbound.
[Thrown class java.lang.IllegalStateException]