Java高性能线程库:Jetlang

Jetlang 提供了一个高性能的Java线程库,该库是 JDK 1.5 中的 java.util.concurrent 包的补充,可用于基于并发消息机制的应用。该类库不提供远程的消息功能,其设计的宗旨是实现一个内存中的消息传递机制:

主要特点有:

  • All messages to a particular Fiber are delivered sequentially. Components can easily keep state without synchronizing data access or worrying about thread races.
  • Single Fiber interface that can be backed by a dedicated thread or a thread pool.
  • Supports single or multiple subscribers for messages.
  • Subscriptions for single events or event batching
  • Single or recurring event scheduling
  • High performance design optimized for low latency and high scalability
  • Publishing is thread safe, allowing easy integration with other threading models.
  • Low Lock Contention – Minimizing lock contention is critical for performance. Other concurrency solutions are limited by a single lock typically on a central thread pool or message queue. Jetlang is optimized for low lock contention. Without a central bottleneck, performance easily scales to the needs of the application.

Fiber fiber = 
new
ThreadFiber();

fiber.start();

final CountDownLatch latch = 
new
CountDownLatch(2);

Runnable toRun = 
new
Runnable(){

   
public
void
run(){

      
latch.countDown();

   
}

};

//enqueue runnable for execution

fiber.execute(toRun);

//repeat to trigger latch a 2nd time

fiber.execute(toRun);

latch.await(10, TimeUnit.SECONDS);

//shutdown thread

fiber.dispose();

项目主页:http://www.open-open.com/lib/view/home/1360159040111

时间: 2024-08-05 12:20:14

Java高性能线程库:Jetlang的相关文章

【Jetlang】一个高性能的Java线程库

actor  Jetlang 提供了一个高性能的Java线程库,该库是 JDK 1.5 中的 java.util.concurrent 包的补充,可用于基于并发消息机制的应用. .net的MS CCR和Retlang:

Java的线程模型

并发不一定要依赖多线程(如PHP中很常见的多进程并发),但是在Java里面谈论并发,大多数都与线程脱不开关系. 线程是比进程更轻量级的调度执行单位,线程的引入,可以把一个进程的资源分配和执行调度分开,各个线程既可以共享进程资源(内存地址.文件I/O等),又可以独立调度(线程是CPU调度的基本单位). 主流的操作系统都提供了线程实现,Java语言则提供了在不同硬件和操作系统平台下对线程操作的统一处理,每个已经执行start()且还未结束的java.lang.Thread类的实例就代表了一个线程.我

Java与线程

线程的实现 1. 使用内核线程实现 直接使用操作系统的内核支持的线程,何种线程由内核来完成线程切换,内核通过操纵调度器(Scheduler)对线程进行调度,并负责将线程的任务映射到各个处理器上. 程序一般不会直接去使用内核线程,而是去使用内核线程的一种高级接口----轻量级进程(Light Wiehgt Process, LWP),它就是我们通常说的线程.轻量级进程与内核线程是1:1的一对一关系. 局限性: 1) 由于是内核线程实现,各种线程操作,如创建,析构及同步,都需要进行系统调用,代价很高

Java之线程状态

Java线程有6种状态: 1.New(新生),使用new Thread(r)创建一个新线程时,该线程处于新生状态,新生状态会为线程的执行做一些准备. 2.Runnable(可执行),调用线程的start方法,使该线程处于可执行状态. 可执行状态不代表该线程一定在执行,而是它具备执行的条件.它可能正在执行,也可能没有在执行,这全然取决于线程调度控制. 3.Blocked(被堵塞).当线程试图获取一个内部的对象锁时,该对象锁被其它线程持有,则该线程进入堵塞状态. 4.Waiting(等待).当在调用

收集的Java科学计算库

将数学.物理.生物.航天.经济学等的计算集成到单一系统架构,提供了细致全面的计算系统. 科学计算框架 Catalano http://www.oschina.net/p/catalano Catalano Framework 是一个 Java 和 Android 的科学计算框架. 主要计算功能: 图像处理 模糊逻辑 数学计算 统计 机器学习 神经网络 科学计算可移植扩展工具包 PETSc http://www.oschina.net/p/petsc PETSc(Portable, Extensi

一种类型安全的Java HTTP客户端库Retrofit

一种类型安全的Java HTTP客户端库Retrofit 作者:chszs,未经博主允许不得转载.经许可的转载需注明作者和博客主页:http://blog.csdn.net/chszs 一.Retrofit介绍 Retrofit是一个开源的.类型安全的HTTP客户端,它适用于Android和Java平台,官方主页为: http://square.github.io/retrofit/ Retrofit需要Java 7以上版本或Android 2.3以上版本的支持. 二.Retrofit依赖 Re

Java 并发 线程的生命周期

Java 并发 线程的生命周期 @author ixenos 线程的生命周期 线程状态: a)     New 新建 b)     Runnable 可运行 c)     Running 运行 (调用getState()时显示为Runnable) d)     Blocked 阻塞 i.          I/O阻塞 (不释放锁) I/O操作完成解除阻塞,进入Runnable状态 ii.          同步阻塞(不释放锁) 运行的线程在获取对象的同步锁时,若该同步锁被别的线程占用,则JVM会

java 多线程—线程怎么来的

并发处理的广泛应用是使得amdah1定律代替摩尔定律成为计算机性能发展源动力的根本原因,是人类压榨计算机运算能力的最有力武器. 并发并非一定得用多线程,多进程也可以,不过java里面谈论并发,大多数与线程脱不开关系. 1.线程的实现 线程是比进程更轻量级的调度执行单位,在linux里面,线程和进程没有什么区别,唯一的就是在地址空间,线程的切换虚拟内存空间依然是相同的,但是进程切换是不同的. 目前主流的操作系统都提供的线程实现,java则提供的线程实现方法都是native的,因为不同的硬件和操作系

基于无锁队列和c++11的高性能线程池

基于无锁队列和c++11的高性能线程池线程使用c++11库和线程池之间的消息通讯使用一个简单的无锁消息队列适用于linux平台,gcc 4.6以上 标签: <无> 代码片段(6)[全屏查看所有代码] 1. [代码]lckfree.h ? 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 // lckfree.h //