没有合适的资源？快使用搜索试试~ 我知道了~

文库首页安全技术网络安全JAVA并发编程深度学习-无锁并行计算框架1

JAVA并发编程深度学习-无锁并行计算框架1

java

深度学习

需积分: 0 1 下载量 28 浏览量 2022-08-08 22:18:40 上传评论收藏 2.22MB DOCX 举报

温馨提示

试读

58页

}}Disruptor costTime = 7458ms并发编程框架核心讲解2.1 Disruptor-QuickStart-基础元素工厂类Disruptor

资源推荐

资源详情

资源评论

JAVA并发编程核心方法与框架-高洪岩著

JAVA并发编程核心方法与框架-高洪岩著 java 多并发经典书籍

《Java并发编程高阶技术-高性能并发框架源码解析与实战》学习.zip

《Java并发编程高阶技术-高性能并发框架源码解析与实战》学习

java:java高级学习，主要包括并发编程，设计模式，性能优化，源码分析，微服务框架，高性能Nginx服务器，互联网高并发解决方案，互联网安全架构，分布式架构，分布式协调工具，分布式解决方案方案

Java java高级学习，主要包括并发编程，设计模式，性能优化，源码分析，微服务框架，高性能Nginx服务器，互联网高并发解决方案，互联网安全架构，分布式架构，分布式协调工具，分布式解决方案方案

java-study:java-study 是本人学习Java过程中记录的一些代码！从Java基础的数据类型、jdk1.8的Lambda、Stream和日期的使用、 IO流、数据集合、多线程使用、并发编程、23种设计模式示例代码、常用的工具类，以及一些常用框架，netty、mina、springboot、kafka、storm、zookeeper、redis、elasticsearch、hbase、hive等等

java-study 介绍是本人学习Java过程中记录的一些代码！从Java基础的数据类型、jdk1.8的使用、IO、集合、线程等等技术以及一些常用框架，netty、mina、springboot、kafka、storm、zookeeper、es、redis、hbase、hive等等。使用下载： git clone https://github.com/xuwujing/java-stud

Java并发编程实践--电子书.rar

Java并发编程实践--电子书.rarJava并发编程实践--电子书.rar

JAVA并发编程实践-中文-高清-带书签-完整版

5星 · 资源好评率100%

JAVA并发编程实践-中文-高清-带书签-完整版(Doug+Lea)JAVA并发编程实践-中文-高清-带书签-完整版(Doug+Lea)

Java并发编程面试题--共87题

4星 · 用户满意度95%

Java语言一个重要的特点就是内置了对并发的支持，让Java大受企业和程序员的欢迎。大多数待遇丰厚的Java开发职位都要求开发者精通多线程技术并且有丰富的Java程序开发、调试、优化经验，所以线程相关的问题在面试中...

JAVA并发编程实践JavaConcurrencyinPractice-中文-高清-带书签-完整版Doug Lea 等著

JAVA并发编程实践JavaConcurrencyinPractice-中文-高清-带书签-完整版Doug Lea 等著

JAVA并发编程实践JavaConcurrencyinPractice-中文-高清-带书签-完整版(Doug Lea)

JAVA并发编程实践JavaConcurrencyinPractie-中文-高清-带书签-完整版(Doug Lea)

JAVA并发编程实践-线程对象与组合对象-学习笔记

使用java.util.concurrent类库构造安全的并发应用程序的基础。共享其实就是某一线程的数据改变对其它线程可见，否则就会出现脏数据。

学习Java技术需要掌握多个方面，包括语言基础、面向对象编程、Java标准库、框架与工具、并发编程、以及其他相关的技

学习Java技术需要掌握多个方面，包括语言基础、面向对象编程、Java标准库、框架与工具、并发编程、以及其他相关的技术。以下是一些Java技术学习的要点： Java语言基础：数据类型、变量和运算符。控制流程语句（if、else、switch、while、for等）。方法和函数的定义与调用。异常处理（try、catch、throw、throws）

java并发编程源码分析-java-learning:Java知识体系学习路线：将会包含了框架源码分析专题、并发编程专题、算法专题和相关实验代

java并发编程源码分析 Java知识体系项目介绍 {以下是码云平台说明，您可以替换为您的项目简介码云是开源中国推出的基于 Git 的代码托管平台（同时支持 SVN）。专为开发者提供稳定、高效、安全的云端软件开发协作平台无论是个人、团队、或是企业，都能够用码云实现代码托管、项目管理、协作开发。企业项目请看 } 软件架构软件架构说明安装教程 xxxx xxxx xxxx 使用说明 xxxx

无锁并行框架Amino -- Concurrent Building Blocks

无锁并行框架Amino -- Concurrent Building Blocks

Java并发编程系列- volatile

Java并发编程系列- volatile；Java并发编程系列- volatile；Java并发编程系列- volatile；Java并发编程系列- volatile；Java并发编程系列- volatile；

java并发编程2

5星 · 资源好评率100%

java并发编程pdf文档第二部分：Java并发编程实战.pdf、Java多线程编程核心技术.pdf、实战Java高并发程序设计.pdf

13-Java并发编程学习宝典.zip

13-Java并发编程学习宝典.zip

Java并发编程实践-电子书1-9章pdf

Java并发编程实践-电子书1-9章pdf。

《java 并发编程实战高清PDF版》

深入讲解java并发编程技术，多线程、锁以及java内存模型等

java并发编程实战源码,java并发编程实战pdf,Java

5星 · 资源好评率100%

java并发编程实战源码附有本书所有源码，maven 导入 eclipse或idea

JAVA 并发编程深度学习-无锁并行计算框架

第1节并发编程与无锁并行计算框架初探

public interface Constants {

int EVENT_NUM_OHM = 100000000;

int EVENT_NUM_FM = 50000000;

int EVENT_NUM_OM = 10000000;

}

public class ArrayBlockingQueue4Test {

public static void main(String[] args) {

final ArrayBlockingQueue<Message> queue = new

ArrayBlockingQueue<>(Constants.EVENT_NUM_OM);

final long startTime = System.currentTimeMillis();

new Thread(()->{

long i = 0;

while (i < Constants.EVENT_NUM_OHM) {

Message message = new Message(i, "c" + i);

try {

queue.put(message);

} catch (InterruptedException e) {

e.printStackTrace();

}

i++;

}

}).start();

new Thread(()->{

int k = 0;

while (k < Constants.EVENT_NUM_OHM) {

try {

queue.take();

} catch (InterruptedException e) {

e.printStackTrace();

}

k++;

}

long endTime = System.currentTimeMillis();

System.out.println("ArrayBlockingQueue costTime = " + (endTime - startTime)

+ "ms");

}).start();

}

ArrayBlockingQueue costTime = 27912ms

public class DataConsumer implements EventHandler<Message> {

private long startTime;

private int i;

public DataConsumer() {

this.startTime = System.currentTimeMillis();

}

public void onEvent(Message data, long seq, boolean bool)

throws Exception {

i++;

if (i == Constants.EVENT_NUM_FM) {

long endTime = System.currentTimeMillis();

System.out.println("Disruptor costTime = " + (endTime - startTime) + "ms");

}

public class DisruptorSingle4Test {

public static void main(String[] args) {

int ringBufferSize = 65536;

final Disruptor<Message> disruptor = new Disruptor<>(

new EventFactory<Message>() {

@Override

public Message newInstance() {

return new Message();

}

ringBufferSize,

Executors.newSingleThreadExecutor(),

ProducerType.SINGLE,

new YieldingWaitStrategy()

);

DataConsumer consumer = new DataConsumer();

disruptor.handleEventsWith(consumer);

disruptor.start();

new Thread(()->{

RingBuffer<Message> ringBuffer = disruptor.getRingBuffer();

for (long i = 0; i < Constants.EVENT_NUM_FM; i++) {

long seq = ringBuffer.next();

Message data = ringBuffer.get(seq);

data.setId(i);

data.setName("c" + i);

ringBuffer.publish(seq);

}

}).start();

}

Disruptor costTime = 7458ms

第2节并发编程框架核心讲解

2.1 Disruptor-QuickStart-基础元素工厂类

Disruptor 实践简介

·Martin Fowler 在自己网站上写了一篇 LMAX 架构的文章

·在文章中他介绍了 LMAX 是一种新型零售金融交易平台

·它能够以很低的延迟产生大量交易

·这个系统建立在 JVM 平台上，其核心是一个业务逻辑处理器

Disruptor 性能及核心

·它能够在一个线程里每秒处理 6 百万订单

·业务逻辑处理器完全是运行在内存中，它使用事件源驱动方式

·业务逻辑处理器的核心是 Disruptor

Disruptor 基本使用

·建立一个工厂 Event 类，用于创建 Event 类实例对象

·需要有一个监听事件类，用于处理数据（Event 类）

·实例化 Disruptor 实例，配置一系列参数，编写 Disruptor 核心组件

·编写生产者组件，向 Disruptor 容器中去投递数据

生成-消费模型

@Data

public class OrderEvent {

private long value;

}

基础元素工厂类

public class OrderEventFactory implements

EventFactory<OrderEvent> {

@Override

public OrderEvent newInstance() {

这个方法就是为了返回空的

OrderEvent

对象

return new OrderEvent();

}

消费端事件处理器

@Slf4j

public class OrderEventHandler implements

EventHandler<OrderEvent> {

@Override

public void onEvent(OrderEvent orderEvent, long l, boolean b)

throws Exception {

log.info("Customer event value:{}",

orderEvent.getValue());

}

生产者组件投递数据

@Data

@AllArgsConstructor

public class OrderEventProducer {

private RingBuffer<OrderEvent> ringBuffer;

public void setData(ByteBuffer byteBuffer){

// 1

在生产者发送消息的时候，首先需要从

ringBuffer

中获取一个

可用的序号

long sequence = ringBuffer.next();

try{

// 2

根据这个序号，找到具体

OrderEvent

元素，注意：此时获

取的

OrderEvent

对象是一个没有被赋值空对象

OrderEvent event = ringBuffer.get(sequence);

// 3

进行实际的赋值处理

event.setValue(byteBuffer.getLong(0));

} finally {

// 4

提交发布操作

ringBuffer.publish(sequence);

}

public class Main {

public static void main(String[] args) {

// 1.

实例化

Disruptor

对象

OrderEventFactory orderEventFactory = new

OrderEventFactory();

int ringBufferSize = 1024 * 1024;

ExecutorService executor =

Executors.newFixedThreadPool(Runtime.getRuntime().availablePro

cessors());

/**

* 1 eventFactory:

消息

(event)

工厂对象

剩余57页未读，继续阅读

评论收藏

内容反馈

资源评论

资源反馈

评论星级较低，若资源使用遇到问题可联系上传者，3个工作日内问题未解决可申请退款~

StoneChan

粉丝: 27
资源: 321

上传资源快速赚钱

我的内容管理展开

我的资源快来上传第一个资源

我的收益

登录查看自己的收益

我的积分登录查看自己的积分

我的C币登录后查看C币余额

我的收藏

我的下载

下载帮助

前往需求广场，查看用户热搜

JAVA并发编程深度学习-无锁并行计算框架1

JAVA并发编程核心方法与框架-高洪岩著

《Java并发编程高阶技术-高性能并发框架源码解析与实战》学习.zip

java:java高级学习，主要包括并发编程，设计模式，性能优化，源码分析，微服务框架，高性能Nginx服务器，互联网高并发解决方案，互联网安全架构，分布式架构，分布式协调工具，分布式解决方案方案

JAVA并发编程实践-线程池-学习笔记

JAVA并发编程实践-线程执行-学习笔记

62-Java并发编程实战

Java并发编程---synchronized关键字

Java并发编程---Thread类

Java并发编程实践-电子书

JAVA并发编程实践-线程安全-学习笔记

JAVA并发编程实践-构建执行程序块-学习笔记

JAVA并发编程学习笔记之CAS操作

JAVA并发编程实践-线程的关闭与取消-学习笔记

Java并发编程实践--电子书.rar

JAVA并发编程实践-中文-高清-带书签-完整版

Java并发编程面试题--共87题

JAVA并发编程实践JavaConcurrencyinPractice-中文-高清-带书签-完整版Doug Lea 等著

JAVA并发编程实践JavaConcurrencyinPractice-中文-高清-带书签-完整版(Doug Lea)

JAVA并发编程实践-线程对象与组合对象-学习笔记

学习Java技术需要掌握多个方面，包括语言基础、面向对象编程、Java标准库、框架与工具、并发编程、以及其他相关的技

java并发编程源码分析-java-learning:Java知识体系学习路线：将会包含了框架源码分析专题、并发编程专题、算法专题和相关实验代

无锁并行框架Amino -- Concurrent Building Blocks

Java并发编程系列- volatile

java并发编程2

13-Java并发编程学习宝典.zip

Java并发编程实践-电子书1-9章pdf

《java 并发编程实战高清PDF版》

java并发编程实战源码,java并发编程实战pdf,Java

最新资源