关注我们

Clojure - 并发编程

在Clojure编程中，大多数数据类型都是不可变的，因此在进行并行编程时，当这些代码在多个处理器上运行时，使用这些数据类型的代码非常安全。但是很多时候，需要共享数据，当涉及到跨多个处理器共享数据时，有必要确保在与多个处理器一起工作时保持数据状态的完整性，这称为并发编程，Clojure支持此类编程。

Clojure中有三种引用类型。

Vars - 更改隔离在线程中。
Refs - 更改在线程之间同步和协调。
Agents - 涉及线程之间的异步独立更改。

关于并行编程，在Clojure中可以进行以下操作。

Transactions - Clojure中的并发基于事务。引用只能在事务内更改。

dosync - 在包含表达式和任何嵌套调用的事务中运行表达式(隐式执行)。如果该线程上没有任何事务，则启动事务。

语法

(dosync expression)

Parameters - “expression"是将出现在dosync块中的一组表达式。

让我们看一个示例，其中我们尝试更改参考变量的值。

无涯教程网

复制代码

(ns clojure.examples.example
   (:gen-class))
(defn Example []
   (def names (ref []))
   (alter names conj "Toolfk"))
(Example)

上面的程序在运行时给出以下错误。

Caused by: java.lang.IllegalStateException: No transaction running
   at clojure.lang.LockingTransaction.getEx(LockingTransaction.java:208)
   at clojure.lang.Ref.alter(Ref.java:173)
   at clojure.core$alter.doInvoke(core.clj:1866)
   at clojure.lang.RestFn.invoke(RestFn.java:443)
   at clojure.examples.example$Example.invoke(main.clj:5)
   at clojure.examples.example$eval8.invoke(main.clj:7)
   at clojure.lang.Compiler.eval(Compiler.java:5424)
   ... 12 more

从错误中您可以清楚地看到，如果不先启动事务，就无法更改引用类型的值。

为了使上面的代码起作用，我们必须像下面的程序中那样将alter命令放在dosync块中。

链接：https://www.learnfk.comhttps://www.learnfk.com/clojure/clojure-concurrent-programming.html

来源：LearnFk无涯教程网

复制代码

(ns clojure.examples.example
   (:gen-class))
(defn Example []
   (def names (ref []))
   
   (defn change [newname]
      (dosync
         (alter names conj newname)))
   (change "Learnfk")
   (change "Toolfk")
   (println @names))
(Example)

上面的程序产生以下输出。

[Learnfk Toolfk]

我们来看另一个dosync的例子。

复制代码

(ns clojure.examples.example
   (:gen-class))
(defn Example []
   (def var1 (ref 10))
   (def var2 (ref 20))
   (println @var1 @var2)
   
   (defn change-value [var1 var2 newvalue]
      (dosync
         (alter var1 - newvalue)
         (alter var2 + newvalue)))
   (change-value var1 var2 20)
   (println @var1 @var2))
(Example)