了解java中的Clojure如何抽象并发性和共享状态_java

来源:脚本之家  责任编辑:小易  

Clojure是一种运行在Java平台上的 Lisp 方言,Lisp是一种以表达性和功能强大著称的编程语言,但人们通常认为它不太适合应用于一般情况,而Clojure的出现彻底改变了这一现状。如今,在任 Java 虚拟机的地方,您都可以利用 Lisp 的强大功能。Java是一门面向对象编程语言,不仅吸收了C++语言的各种优点,还摒弃了C++里难以理解的多继承、指针等概念,因此Java语言具有功能强大和简单易用两个特征。Java语言作为静态面向对象编程语言的代表,极好地实现了面向对象理论,允许程序员以优雅的思维方式进行复杂的编程ITjob网上有详细的介绍。这两个各有特点,各有所长,不存在那个好或者不好。看你觉得那个更感兴趣,兴趣是最好的老师。望采纳www.zgxue.com防采集请勿采集本网。

前言

在所有 Java 下一代语言中,Clojure 拥有最激进的并发性机制和功能。Groovy 和 Scala 都为并发性提供了改善的抽象和语法糖的一种组合,而 Clojure 坚持了它始终在 JVM 上提供独一无二的行为的强硬立场。在本期 Java 下一代 中,我将介绍 Clojure 中众多并发性选项的一部分。首先是为 Clojure 中易变的引用提供支撑的基础抽象:epochal 时间模型。

new User(name);这个User类有个自己的构造方法比如<pre t=\"code\" l=\"java\">class User(){ private String name;public User(String name){ this.name=name;} }

Epochal 事件模型

clojure实现java类 现在需要将clojure生成的Java类的class文件放在指定的目录下,然后让core.clj能够引用到这个class文件。

或许 Clojure 与其他语言最显著的区别与易变的状态和值 密切相关。Clojure 中的值 可以是任何用户感兴趣的数据:数字 42、映射结构 {:first-name "Neal :last-name "Ford"} 或某些更大型的数据结构,比如 Wikipedia。基本来讲,Clojure 语言对待所有值就像其他语言对待数字一样。数字 42 是一个值,您不能重新定义它。但可对该值应用一个函数,返回另一个值。例如,(inc 42) 返回值 43。

印刷错误,英文版里是: (def writer(java.io.StringWriter.))

在 Java 和其他基于 C 的语言中,变量 同时持有身份和值,这是让并发性在 Java 语言中如此难以实现的因素之一。语言设计人员在线程抽象之前创建了变量抽象,变量的设计没有考虑为并发性增加的复杂性。因为 Java 中的变量假设只有单个线程,所以在多线程环境中,需要像同步块这样麻烦的机制来保护变量。Clojure 的设计人员 Rich Hickey 让交织(complect) 这个古老的词汇恢复了活力(交织这个词被定义为 “缠绕或编织”),用于描述 Java 变量中的设计缺陷。

Clojure 的难点有三个: 对于 Java 程序员来说,Clojure对于其它程序员来说,Clojure 有大量的符号,大量的平铺的函数(Overview-Clojure v1.6 API documentation),缺乏一个逐步了解的「线索」

Clojure 将值 与引用 分开。在 Clojure 世界观中,数据以一系列不变的值的形式存在,如图 1 所示。

你说的这些JVM语言都是最后编译成Class文件在JVM上面执行的,如果不了解JVM,那么很多Java语言的基础知识你都不可能学好,而且JVM参数调优已经成Java程序员必备的知识了,但是如果你不懂JVM的GC算法和各种

图 1. epochal 时间模型中的值

图 1 显示,像 v1 这样的独立的值表示 42 或 Wikipedia 等数据,使用方框表示。与值独立的是函数,它们获取值作为参数并生成新值,如图 2 所示。

图 2. epochal 时间模型中的函数

图 2 将函数显示为与值独立的圆圈。函数调用会生成新值,使用值作为参数和结果。一连串的值保存在一个引用 中,它表示变量的身份。随着时间的推移,此身份可能指向不同的值(由于函数应用),但身份从不更改,如图 3 中的虚线所示。

图 3. epochal 时间模型中的引用

在图 3 中,整幅图表示一个引用随时间的变化。虚线是一个引用,它持有其生存期内的一连串的值。可在某个时刻向引用分配一个新的不变值;引用指向的目标可更改,而无需更改该引用。

在引用的生存期中,一个或多个观察者(其他程序、用户界面、任何对该引用持有的值感兴趣的对象)将解除引用它,查看它的值(或许还执行某种操作),如图 4 所示。

图 4. 解除引用

在图 4 中,观察者(有两种楔形表示)可持有引用本身(由来自虚线引用的箭头表示),或者可解除引用它,检索它的值(由来自该值的箭头表示)。例如,您可能有一个函数,它以一个传递给您的数据库连接作为参数,您进而将该参数传递给一个更低级的持久性函数。在此情况下,您持有该引用,但从不需要它的值;持久性函数可能会解除引用它,以获取它的值来连接到一个数据库。

请注意,图 4 中的观察者不会进行协调 — 它们完全不依赖彼此。此结构使得 Clojure 运行时能够在整个语言中保证了一些有用的属性,比如决不允许读取程序阻塞,这使得读取操作变得非常高效。如果您希望更改一个引用(也就是说,将它指向一个不同的值),可使用 Clojure 的一个 API 来执行更新,这会采用 epochal 时间模型。

epochal 时间模型为整个 Clojure 中的引用更新提供了支持。因为运行时控制所有更新,所以它可防御线程冲突,开发人员在不太复杂的语言中必须争用线程。

Clojure 拥有广泛的方式来更新引用,具体依赖于您想要何种特征。接下来,我将讨论两种方式:简单的原子 和复杂的软件事务内存。

原子

Clojure 中的原子 是对数据一个原子部分的引用,无论该部分有多大。您创建一个 atom 并初始化它,然后应用一个突变函数。这里,我为一个原子创建了一个称为 counter 的引用,将它初始化为 0。如果我希望将引用更新到一个新值,我可使用 (swap!) 这样的函数,它原子化地为该引用换入一个新值:

(def counter (atom 0))(swap! counter + 10)

根据 Clojure 中的惯例,突变函数的名称以一个感叹号结尾。(swap!) 函数接受该引用、要应用的函数(在本例中为 + 运算符)和任何其他参数。

Clojure 原子持有任何大小的数据,而不只是原始值。例如,我可围绕一个 person 映射创建一个原子引用,并使用 map 函数更新它。使用 (create-person) 函数(未显示),我在一个原子中创建一个 person 记录,然后使用 (swap!) 和 (assoc ) 更新该引用,这会更新一个映射关联:

(def person (atom (create-person)))(swap! person assoc :name "John")

原子还会通过 (compare-and-set!) 函数,使用原子实现一个通用的乐观锁定模式:

(compare-and-set! a 0 42)=> false(compare-and-set! a 1 7)= true

(compare-and-set!) 函数接受 3 个参数:原子引用、想要的现有值和新值。如果原子的值与想要的值不匹配,更新不会发生,函数会返回 false。

Clojure 有各种各样的机制都遵循引用语义。例如,promise(是一种不同的引用)承诺在以后提供一个值。这里,我创建对一个名为 number-later 的 promise 的引用。此代码不会生成任何值,就像它对最终会这么做的承诺一样。调用 (deliver ) 函数时,一个值会绑定到 number-later:

(def number-later (promise))(deliver number-later 42)

尽管此示例使用了 Clojure 中的 futures 库,但引用语义与简单的原子保持一致。

软件事务内存

没有其他任何 Clojure 特性获得了比软件事务内存 (STM) 更多的关注,这是 Clojure 以 Java 语言封装垃圾收集的方式来封装并发性的内部机制。换句话说,您可编写高性能的多线程 Clojure 应用程序,而从不考虑同步块、死锁、线程库等。

Clojure 封装并发性的方式是,通过 STM 控制引用的所有突变。更新一个引用(惟一的易变抽象)时,必须在一个事务中执行,以使 Clojure 运行时能够管理更新。考虑一个经典的银行问题:向一个帐户中存款,同时向另一个帐户贷款。清单 1 显示了一个简单的 Clojure 解决方案。

清单 1. 银行交易

(defn transfer[from to amount](dosync(alter from - amount)(alter to + amount)))

在 清单 1 中,我定义了一个 (transfer ) 函数,它接受 3 个参数:from 和 to 帐户 — 二者都是引用 — 以及金额。我从 from 帐户中减去该金额,将它添加到 to 帐户中,但此操作必须与 (dosync ) 事务一起发生。如果我在事务块的外部尝试一个 (alter ) 调用,更新会失败并抛出一个 IllegalStateException:

(alter from - 1)=>> IllegalStateException No transaction running

在 清单 1 中,(alter ) 函数仍然遵守 epochal 时间模型,但使用 STM 来确保两个操作都完成或都未完成。为此,STM — 非常像一个数据库服务器 — 临时重试阻塞的操作,所以您的更新函数在更新之外不应有任何副作用。例如,如果您的函数还写入一个日志,由于不断重试,您可能会看到多个日志条目。STM 还会随未解决事务的时长增长而逐步提高它们的优先级,显示数据库引擎中的其他更常见的行为。

STM 的使用很简单,但底层机制很复杂。从名称可以看出,STM 是一个事务系统。STM 实现了 ACID 事务标准的 ACI 部分:所有更改都是原子性、一致 和隔离的。ACID 的耐久 部分在这里不适用,因为 STM 在内存中操作。很少看到将像 STM 这样的高性能机制内置于一种语言的核心中;Haskell 是惟一认真实现了 STM 的另一种主流语言 — 不要奇怪,因为 Haskell(像 Clojure 一样)非常喜欢不变性。(.NET 生态系统曾尝试构建一个 STM 管理器,但最终放弃了,因为处理事务和不变性变得太复杂了。)

缩减程序(reducer)和数字分类

如果不讨论 上一期 中的数字分类器问题的替代实现,并行性介绍都是不完整的。清单 2 显示了一个没有并行性的原子版本。

清单 2. Clojure 中的数字分类器

(defn classify [num](let [facts (->> (range 1 (inc num))(filter #(= 0 (rem num %))))sum (reduce + facts)aliquot-sum (- sum num)](cond(= aliquot-sum num) :perfect(> aliquot-sum num) :abundant(< aliquot-sum num) :deficient)))

清单 2 中的分类器版本浓缩为单个函数,它返回一个 Clojure 关键字(由一个前导冒号表示)。(let ) 块使我能够建立局部绑定。为了确定因数,我使用 thread-last 运算符来过滤数字范围,让代码更有序。sum 和 aliquot-sum 的计算都很简单;一个数字的真因数和 是它的因数之和减去它本身,这使我的比较代码更简单。该函数的最后一行是 (cond ) 语句,它针对计算的值来计算 aliquot-sum,返回合适的关键字枚举。此代码的一个有趣之处是,我以前的实现中的方法在这个版本中折叠为简单的赋值。在计算足够简单和简洁时,您通常需要创建的函数更少。

Clojure 包含一个称为 缩减程序 的强大的并发性库。(有关缩减程序库的开发过程的解释 — 包括为利用最新的 JVM 原生的 fork/join 工具而进行的优化 — 是一个吸引人的故事。)缩减程序库提供了常见运算的就地替换,比如 map、filter 和 reduce,使这些预算能够自动利用多个线程。例如,将标准的 (map ) 替换为 (r/map )(r/ 是缩减程序的命名空间),会导致您的映射操作自动被运行时并行化。

清单 3 给出了一个利用了缩减程序的数字分类器版本。

清单 3. 使用了缩减程序库的分类器

(ns pperfect.core(:require [clojure.core.reducers :as r]))(defn classify-with-reducer [num](let [facts (->> (range 1 (inc num))(r/filter #(= 0 (rem num %))))sum (r/reduce + facts)aliquot-sum (- sum num)](cond(= aliquot-sum num) :perfect(> aliquot-sum num) :abundant(< aliquot-sum num) :deficient)))

必须仔细观察,才能找出 清单 2 和 清单 3 之间的区别。惟一的区别是引入了缩减程序命名空间和别名,向 filter 和 reduce 都添加了 r/。借助这些细微的更改,我的过滤和缩减操作现在可自动使用多个线程。

结束语

本期介绍了 Clojure 中的一些并发性选项,这是一个内容丰富的主题区域。我讨论了核心的底层抽象 — epochal 时间模型 — 展示了原子和 STM 如何使用此概念。我还演示了一种简单的就地替换库,它使现有的应用程序能够使用高级并发性功能,比如 fork/join。

Clojure 中还有其他许多并发性选项,包括更简单的并行函数,比如 pmap (parallel map)。Clojure 还包含代理 — 绑定到一个池中的线程上的自主工作者(由系统或用户定义),与 Scala 的 actor 大体相似。Clojure 还融入了 Java 语言中所有现在的并发性进步,使它能轻松地使用 fork/join 等现代库。

或许比任何其他 Clojure 特性都更明显,并发性工具显示了 Clojure 生态系统的工程设计重点:充分利用语言特性来构建强大的抽象。Clojure 没有尝试创建一个 Lispy 版的 Java。设计者从根本上重新思考了核心基础设施和实现。

一个Java背景的爱好者,学习Clojure语言具备得天独厚的优势。其原因在于:了解Java—受益颇多:class-paths(类路径),class loaders(类加载器),constructors(构造函数),methods(方法),static methods(静态方法),standard libraries(标准库),ar files(jar 文件)等等。了解JVM—heap(堆),garbage collection(垃圾回收),perm-gen space,debugging(调试),profiling(分析),performance tuning(性能优化)等等。Java生态库—采用什么样的日志框架?哪种类型的Web服务器?数据库驱动?等等。Maven situation—有时你必须知道在lein情况下会发生什么状况?了解如何构建大型代码基地—Clojure代码库在不断壮大。面向对象分析与设计—这个与弄清函数的位置设置相似。Clojure是一门现代化的LISP完整的宏系统,一门函数式编程语言,它还具有并发语义,基于JVM访问这些库等等。Clojure是JVM上的一门新的语言,类似Groovy,Jyphon和JRuby,它能动态的、简洁的、无缝的与Java进行交互操作内容来自www.zgxue.com请勿采集。


  • 本文相关:
  • java实现runnable接口适合资源的共享
  • java利用happen-before规则如何实现共享变量的同步操作详解
  • java并发系列之abstractqueuedsynchronizer源码分析(共享模式)
  • java编程多线程之共享数据代码详解
  • java使用wait() notify()方法操作共享资源详解
  • 浅谈java io流——四大抽象类
  • java抽象类的概念讲解
  • java使用抽象工厂模式实现的肯德基消费案例详解
  • java设计模式之工厂模式分析【简单工厂、工厂方法、抽象工厂】
  • java设计模式之抽象工厂模式
  • 详解java中abstractmap抽象类
  • 简单谈谈rxjava和多线程并发
  • 设置tomcat启用gzip压缩的具体操作方法
  • java集合框架详解
  • java修饰符 abstract,static,final 的区别详解
  • springboot快速构建应用程序方法介绍
  • java 多线程优先级实例详解
  • java生成图形验证码工具类
  • android读取本地或网络图片并转换为bitmap
  • java list转换成string数组几种实现方式详解
  • ubuntu 安装 jdk8 的两种方法(总结)
  • 为何Java程序员学习Clojure有优势?
  • clojure和java哪个更好
  • 从一小段代码看 Clojure 和 Java 解决问题的差异
  • 没有Java基础的C码农适合从Clojure开始学FP吗?
  • clojure 中怎么使用java对象的变量
  • clojure和java代码互操作后是不是就变成了可变类型
  • clojure 使用 java 包的问题。包是(clojure.java.io.StringWriter.)
  • Clojure,Java,Python,Ruby 的学习曲线陡峭程度有哪些区别
  • 为什么无论Scala,Clojure,Groovy和JAVA都要学JVM
  • 为什么要选择Clojure
  • 网站首页网页制作脚本下载服务器操作系统网站运营平面设计媒体动画电脑基础硬件教程网络安全c#教程vbvb.netc 语言java编程delphijavaandroidiosswiftscala易语言汇编语言其它相关首页javajava实现runnable接口适合资源的共享java利用happen-before规则如何实现共享变量的同步操作详解java并发系列之abstractqueuedsynchronizer源码分析(共享模式)java编程多线程之共享数据代码详解java使用wait() notify()方法操作共享资源详解浅谈java io流——四大抽象类java抽象类的概念讲解java使用抽象工厂模式实现的肯德基消费案例详解java设计模式之工厂模式分析【简单工厂、工厂方法、抽象工厂】java设计模式之抽象工厂模式详解java中abstractmap抽象类简单谈谈rxjava和多线程并发设置tomcat启用gzip压缩的具体操作方法java集合框架详解java修饰符 abstract,static,final 的区别详解springboot快速构建应用程序方法介绍java 多线程优先级实例详解java生成图形验证码工具类android读取本地或网络图片并转换为bitmapjava list转换成string数组几种实现方式详解ubuntu 安装 jdk8 的两种方法(总结)java使double保留两位小数的多方java8 十大新特性详解java.net.socketexception: connjava写入文件的几种方法分享java环境变量的设置方法(图文教程java 十六进制与字符串的转换java list用法示例详解java中file类的使用方法javaweb实现文件上传下载功能实例java 字符串截取的三种方法(推荐浅谈java操作符与其优先级比较常用uml类图几种关系的小结java网络编程实现的简单端口扫描器示例从helloworld和文档注释开始入门java编程spring boot缓存实战 ehcache示例java中封装的实现方法详解java 文件和byte互转的实例java虚拟机gc日志分析如何使用spring resttemplate访问restfuljava容器arraylist知识点总结
    免责声明 - 关于我们 - 联系我们 - 广告联系 - 友情链接 - 帮助中心 - 频道导航
    Copyright © 2017 www.zgxue.com All Rights Reserved