Java 异步处理框架 ParSeq

Apache
Java
跨平台
LinkedIn
2015-05-10
小编辑

ParSeq 是一个简化 Java 编写异步处理代码的框架,优点:

  • 异步操作的并行处理

  • 顺序执行非堵塞计算

  • 通过任务组合实现代码的重用

  • 简单的错误传播和恢复

  • 执行跟踪和可视化

示例代码:

import com.linkedin.parseq.Engine;
import com.linkedin.parseq.EngineBuilder;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;

// ...

final int numCores = Runtime.getRuntime().availableProcessors();
final ExecutorService taskScheduler = Executors.newFixedThreadPool(numCores + 1);
final ScheduledExecutorService timerScheduler = Executors.newSingleThreadScheduledExecutor();

final Engine engine = new EngineBuilder()
    .setTaskExecutor(taskScheduler)
    .setTimerScheduler(timerScheduler)
    .build();

    

engine.shutdown();
engine.awaitTermination(1, TimeUnit.SECONDS);
taskScheduler.shutdown();
timerScheduler.shutdown();
的码云指数为
超过 的项目
加载中
此软件有 4 条评论,请先登录后再查看。

暂无资讯

暂无问答

ParSeq调研

ParSeq是LinkedIn开源的异步并行框架。具有如下优点: 1、异步操作并行化处理 2、顺序执行非阻塞性计算 3、通过任务组合实现代码重用 4、简单的错误传播和恢复机制 5、执行跟踪和可视化...

2015/07/27 21:48
905
1
LinkedIn的Parseq + ning.httpclient异步请求框架的使用

## 1. Maven配置 ``` xml com.linkedin.parseq parseq 2.6.3 com.linkedin.parseq parseq-http-client 2.6.3 ``` ## 2. 创建以及关闭线程池引擎Engine ``` java private static ExecutorServ...

2016/12/02 18:38
289
1
Kafka总结

什么是Kafka 由LinkedIn在11年开源,还有例如:分布式数据同步系统Databus、高性能计算引擎Cubert、Java异步处理框架ParSeq。 Kafka基本概念 Producer:消息和数据的生产者,向Kafka的一个t...

2019/03/31 21:44
8
0
Scala’s parallel collections

Scala 2.9 introduced parallel collections, which mirror most of the existing collections with a parallel version. Collections that have been parallelized this way have received ...

2012/01/20 14:45
265
0
Akka的Actor编程

Akka的Actor编程

2014/07/04 17:52
632
0
Scala学习(十三)集合

1.主要集合特质 构成Scala集合继承层级最重要的特质 Iterable指的是那些能够生成用来访问集合中所有元素的Iterator的集合 Seq是一个有先后次序的值得序列,比如数组或列表。IndexedSeq允许我...

2018/10/11 11:03
71
0
Azkaban安装及分布式部署(multiple-executor)

参考文章:https://blog.csdn.net/weixin_35852328/article/details/79327996 官网:https://azkaban.readthedocs.io/en/latest/   Azkaban是由Linkedin开源的一个批量工作流任务调度器。用...

2019/04/25 11:39
55
0

没有更多内容

加载失败,请刷新页面

没有更多内容

返回顶部
顶部