- 浏览: 610989 次
- 性别:
- 来自: 大连
文章分类
最新评论
-
fei33423:
同意你的说法. hbase 的强一致性分为两部分来说. 数据分 ...
浅谈Hbase 的强一致性 -
zengwenbo5566:
,高人,刚安装了 genymotion 那个附带 virtu ...
VirtualBox报错Unable to load R3 module GetLastError=1790 (VERR_UNRESOLVED_ERROR -
kabike:
QQ1289714862 写道这代码有问题吧 bar1 bar ...
AtomicBoolean运用 -
QQ1289714862:
这代码有问题吧 bar1 bar2 那来的 你是不是new了两 ...
AtomicBoolean运用 -
DEMONU:
需要依赖这么多东西啊
hbase 0.96和hadoop 2.2 java 客户端的jar依赖
最近看了下clojure的并发,其中提到了agent.agent的原理是把对agent的action提交到线程池中运行.它保证线程安全的措施是对每一个agent,同时只有一个actio
在运行.
下面做一个简单的对比,多个线程多次对同一个StringBuilder进行append,如果不同步,结果是不正确的.
输出结果不是ITERATION_NUMBER * THREAD_NUMBER
可以用synchronized或者java 1.5里的lock来同步,也可以仿照agent的原理,不使用同步机制,而是让action顺序执行
结果表明,让action顺序执行,而不使用lock或者synchronized等手段,效率确实比较高.
在运行.
下面做一个简单的对比,多个线程多次对同一个StringBuilder进行append,如果不同步,结果是不正确的.
final StringBuilder sb = new StringBuilder(); ExecutorService pool = Executors.newFixedThreadPool(Runtime .getRuntime().availableProcessors() + 2); for (int i = 0; i < THREAD_NUMBER; i++) { pool.submit(new Runnable() { @Override public void run() { for (int j = 0; j < ITERATION_NUMBER; j++) { sb.append(bar); } } }); } pool.shutdown(); pool.awaitTermination(60, TimeUnit.SECONDS); String s = sb.toString(); System.out.println(s.length() / bar.length());
输出结果不是ITERATION_NUMBER * THREAD_NUMBER
可以用synchronized或者java 1.5里的lock来同步,也可以仿照agent的原理,不使用同步机制,而是让action顺序执行
结果表明,让action顺序执行,而不使用lock或者synchronized等手段,效率确实比较高.
package foo.concurrency; import java.util.concurrent.Callable; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.TimeUnit; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; public class ClojureAgent { private static String bar = "log from full line a very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very long line\n"; private static int ITERATION_NUMBER = 4000; private static int THREAD_NUMBER = 6; public static void main(String[] args) throws Exception { long start = System.currentTimeMillis(); base(); System.out.println("time is " + (System.currentTimeMillis() - start)); start = System.currentTimeMillis(); sync(); System.out.println("time is " + (System.currentTimeMillis() - start)); start = System.currentTimeMillis(); lock(); System.out.println("time is " + (System.currentTimeMillis() - start)); start = System.currentTimeMillis(); pool(); System.out.println("time is " + (System.currentTimeMillis() - start)); } private static void pool() throws Exception { final StringBuilder sb = new StringBuilder(); ExecutorService pool = Executors.newFixedThreadPool(Runtime .getRuntime().availableProcessors() + 2); for (int i = 0; i < THREAD_NUMBER; i++) { pool.submit(new Callable<Object>() { @Override public Object call() throws Exception { for (int j = 0; j < ITERATION_NUMBER; j++) { sb.append(bar); } return null; } }).get(); } pool.shutdown(); pool.awaitTermination(60, TimeUnit.SECONDS); String s = sb.toString(); System.out.println(s.length() / bar.length()); } private static void sync() throws Exception { final StringBuilder sb = new StringBuilder(); ExecutorService pool = Executors.newFixedThreadPool(Runtime .getRuntime().availableProcessors() + 2); for (int i = 0; i < THREAD_NUMBER; i++) { pool.submit(new Runnable() { @Override public void run() { for (int j = 0; j < ITERATION_NUMBER; j++) { synchronized (sb) { sb.append(bar); } } } }); } pool.shutdown(); pool.awaitTermination(60, TimeUnit.SECONDS); String s = sb.toString(); System.out.println(s.length() / bar.length()); } private static void lock() throws Exception { final Lock lock = new ReentrantLock(); final StringBuilder sb = new StringBuilder(); ExecutorService pool = Executors.newFixedThreadPool(Runtime .getRuntime().availableProcessors() + 2); for (int i = 0; i < THREAD_NUMBER; i++) { pool.submit(new Runnable() { @Override public void run() { for (int j = 0; j < ITERATION_NUMBER; j++) { lock.lock(); try { sb.append(bar); } finally { lock.unlock(); } } } }); } pool.shutdown(); pool.awaitTermination(60, TimeUnit.SECONDS); String s = sb.toString(); System.out.println(s.length() / bar.length()); } private static void base() throws Exception { final StringBuilder sb = new StringBuilder(); ExecutorService pool = Executors.newFixedThreadPool(Runtime .getRuntime().availableProcessors() + 2); for (int i = 0; i < THREAD_NUMBER; i++) { pool.submit(new Runnable() { @Override public void run() { for (int j = 0; j < ITERATION_NUMBER; j++) { sb.append(bar); } } }); } pool.shutdown(); pool.awaitTermination(60, TimeUnit.SECONDS); String s = sb.toString(); System.out.println(s.length() / bar.length()); } }
发表评论
-
禁用vim中自动插入注释
2018-05-20 11:36 915我将一个配置文件复制到粘贴板,粘贴到另一个vim窗口的时候,如 ... -
maven查找所有依赖的license类型
2017-03-27 20:24 1361mvn project-info-reports:depend ... -
一些命令
2016-12-27 15:45 5351 maven assembly插件打包snapshot版本的 ... -
thrift使用中的一些问题
2015-05-07 11:11 4811 TSimpleServer居然是单线程阻塞式server ... -
maven的maven.test.skip和skipTests
2015-03-25 18:04 584maven.test.skip连编译test类都skip了 引 ... -
同步hadoop配置文件
2015-01-08 10:54 756#!/bin/bash HADOOP_HOME=/usr/l ... -
hibernate one to many 查询返回了重复的数据
2014-12-24 23:38 1364很奇怪为什么设计成这样... https://develope ... -
用eclipse来debug
2014-12-24 23:30 612不错的文章,好多debug技巧 http://www.voge ... -
修改vim里注释的颜色
2014-11-12 18:40 1303vim里蓝色的注释太难以看清楚了,在~/.vimrc里加入 h ... -
VirtualBox报错Unable to load R3 module GetLastError=1790 (VERR_UNRESOLVED_ERROR
2014-11-12 12:53 3974在win7上VirtualBox创建个虚拟机各种莫名其妙的错误 ... -
maven repository损坏导致eclipse无法将web工程发布到tomcat
2014-09-17 16:07 2312在eclipse中建立的maven的web工程,发布到tomc ... -
maven工程中解决spring的依赖问题
2014-06-27 15:54 848在maven工程中,添加了spring-aop的依赖,没想到启 ... -
C# winform程序提交带文件的form
2014-06-25 11:47 1224在html页面里,可以在form里提交file和普通input ... -
windows7 下以其他用户运行程序
2014-04-21 09:49 830windows7 下如果想以其他用户运行程序,可以按住shif ... -
tomcat中无法运行solr 4.6
2014-02-25 10:52 667运行tomcat后solr app没有部署成功.报错是 引用 ... -
eclipse 链接外部文件夹
2014-02-21 10:14 1281http://lippeng.iteye.com/blog/9 ... -
dbunit进行数据库操作的测试
2013-02-21 21:26 3674j2ee程序好多都涉及到了数据库操作,这时进行mock测试就没 ... -
搜索引擎site关键字的站内搜索
2013-01-30 15:20 1240比如google里搜索dom element,老是有些乱七八糟 ... -
eclipse重新import被删除的项目
2013-01-14 10:55 4099eclipse工作区里项目太多了,所以删了几个(但是没物理删除 ... -
git创建branch 报错fatal: Not a valid object name: 'master'.
2013-01-11 13:01 21917听说git比svn的branch功能好,所以装了个msysgi ...
相关推荐
- **并发模型**:Clojure提供了原子、代理(agent)、参考(reference)等机制,用于实现高效的并发编程。 - **并行编程**:通过利用不可变数据结构和函数式编程的特性,Clojure简化了并行编程的复杂度。 #### 七、高级...
在Clojure中,状态管理是编程的一个重要方面,特别是对于那些需要处理持久化或变化数据的应用程序。Clojure,作为一种Lisp方言,以其对函数式编程的强调而著名,但同样也提供了处理状态的能力。本篇文章将深入探讨...
4. **引用与原子性**:Clojure中的`ref`、`agent`和`atom`是处理并发的工具。其中,`atom`是最基础的,用于管理可变状态,具有原子性操作。 5. **宏**(Macros):Clojure允许用户创建自己的语法,这是Lisp家族的一...
- **并行和并发**:Clojure的future和agent需要考虑如何在Rust中实现线程安全和异步操作。 项目`clojure-rust-master`可能包含以下内容: - **源代码**:编译器的实现,通常包括解析器、转换器和代码生成器的源代码...
在`user-agent-master`这个项目中,很可能包含了上述步骤的实现,通过阅读源代码,我们可以深入理解Clojure如何处理字符串解析问题,以及如何构建高效的函数式程序。对于Clojure开发者来说,这是一个学习和实践的好...
本文将深入探讨如何在Clojure环境中运行TensorFlow,利用Java互操作性(Java-Interop)来实现这一目标。 首先,理解Clojure与Java的互操作性是关键。由于Clojure是构建在JVM上的,因此可以直接调用Java库,包括...
Clojure 1.3.0 是一个重要的版本更新,它基于 Lisp 编程语言的现代实现,专注于在Java平台上提供高效、并发和功能性的编程体验。这个版本在Clojure的历史发展中扮演了关键的角色,引入了许多改进和新特性,旨在提升...
利用Clojure的agent、ref和atom等核心并发工具,开发者可以在不引入传统并发问题(如竞态条件和死锁)的情况下,轻松地处理游戏中的并行任务,如更新多个游戏实体的状态或执行异步I/O操作。 至于项目本身,"water-...
《温柔的Clojure》是基于David Touretzky的著作《Common Lisp:符号计算的温和介绍》的一系列练习,现在我们将其转化为Clojure语言来实现。这个资源旨在帮助读者深入理解Clojure这门函数式编程语言,同时也为那些...
Cloture是Common Lisp中Clojure的实现。 首先,它旨在与Common Lisp良好地互操作。 Lijup阅读器读取Clojure,而Clojure名称空间是Lisp包。 Cloture处于非常早期的阶段(pre-alpha),但是它已经发展到足以加载,...
3. **Agents**:`agent` 用于异步更新,它们在后台线程中执行任务,简化了异步编程。 ### 四、与 Java 平台的融合 1. **Interop with Java**:Clojure 可以无缝集成 Java 代码,可以直接调用 Java 类库,使得 ...
- **动态性**:Clojure 允许在运行时改变变量的值,通过 var 和 binding 实现。 - **引用类型**:ref、atom、agent 和 promise 用于并发编程,它们保证了状态的一致性和协调。 - **多态性**:Clojure 的协议...
`agent`和`atom`是Clojure中处理并发的两种主要方式,它们提供了一种安全地更新共享状态的方式。 7. **ClojureScript**:Clojure也有一个用于编写JavaScript的版本,称为ClojureScript,它允许Clojure代码编译成...
符合RFC 6570( )中指定的URI模板的Clojure实现,符合级别4 uritemplate uritemplate-clj首先公开uritemplate函数,以URI模板和值映射为输入并返回填充的模板: user=> ( ns test # _=> ( :require [uri...
- **Ref** 和 **Agent**:Clojure的并发模型还包括`Ref`(用于协调多个并发修改)和`Agent`(异步更新)。 6. **REPL驱动开发** - **读-求值-打印循环(REPL)**:Clojure的核心开发工具,允许快速测试代码,迭代...
然而,为了处理状态,Clojure引入了`ref`、`atom`、`agent`等引用类型,它们提供了一种受控的状态变化机制,确保了并发安全。 5. **宏与元编程** Clojure的Lisp特性体现在其强大的宏系统,宏可以在编译时生成代码...
其中,向量和映射都是可变的,但可以通过创建不可变数据结构(如PersistentVector和PersistentHashMap)来实现高效的更新操作,这是Clojure处理并发的关键。 Clojure提供了丰富的内置函数和宏,如`map`、`reduce`、...