`
javaOpen
  • 浏览: 124445 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

Java Concurrency(java 并发)

    博客分类：
  • J2SE
Java多线程数据结构JVM 
阅读更多

【转】http://www.blogjava.net/vincent/archive/2009/07/16/287055.html

关于 Java Concurrency

 
   自从Java诞生之时，Java 就支持并行的概念，比如线程和锁机制。这个教程帮助开发多线程Java程序员能够理解核心的Java并行理念以及如何使用他们。 内容涉及到Java语言中的线程， 重练级以及轻量级同步机制 以及JavaSE 5 中的锁，原子量 并行容器，线程调度 以及线程执行者。 开发人员使用这些知识能够开发好并发线程安全的Java 应用程序。 

Java 并行的概念（Java Concurrency Concepts）

 

概念

描述

Java 内存模型

在JavaSE5 JSR133规范中详细定义了Java内存模型 Java Memory Model（JMM），该模型定义了相关的操作 比如读,写操作，以及在监视器上的同步。 这些操作按 Happens-before的顺序。

这个定义保证了一个线程可以看到另一个线程操作的结果，同时保证了同步的程序， 以及如何定义一个不变的属性 等等。

监视器

在Java中，任何一个对象都有一个监视器，来排斥共享访问临界区域的代码。这些临界区可以是一个方法 或者是一段代码块，这些临界区域作为同步块。线程只有获取该监视器才能执行同步块的代码。当一个线程到达这块代码是，首先等待来确定是否其他线程已经释放这个监控器。监控器除了排斥共享访问，还能通过Wait 和Notify来协调线程之间的交互。

原子属性

除了Double 和long类型，其他的简单类型都是原子类型。Double和long 类型的修改在JVM分为两个不封。为了保证更新共享的Double和Long类型，你应该将Double和long 的属性作为Volatile 或者将修改代码放入同步块中。

竞争情况

当许多线程在一系列的访问共享资源操作中，并且结果跟操作顺便有关系的时候，就发生了竞争情况。

数据竞争

数据竞争涉及到当许多线程访问不是non-final或者non-volatile 并没有合适的同步机制的属性时，JMM不能保证不同步的访问共享的熟悉。数据竞争导致比个预知的行为。

 

自公布

 

还没有通过构造方法实例化对象之前，把这个对象的引用公布时不安全的。

一种是通过注册一个监听器，当初始化的时候回调来发布引用。

另一种是在构造方法里面启动线程。这两种都会导致其他线程引用部分初始化的对象。

Final属性

Final属性必须显示的赋值，否则就会有编译错误。一旦赋值，不能被修改。将一个对象引用标记为Final只能保证该引用不会被修改，但该对象可以被修改。比如一个Final ArrayIist不能改变为另一个ArrayList 但你可以添加或者修改这个List的对象。在构造方法之后，一个对象的Final 属性是冻结的，保证了对象被安全的发布。其他线程可以在构造方法时看到该变量，甚至在缺乏同步的机制下。

 

不变对象

Final 属性从语义上能够保证创建不变对象。而不变对象可以再没有同步机制下多线程共享和读取。为保证该对象是不变的，必须保证如下：

这个对象被安全的发布，this引用不能在构造方法的时候被发布

所有的属性都是Final的

应用的对象必须保证在构造方法之后不能被修改。

这个对象需要声明为Final 保证子类违法这些原则。

 

 

Protecting shared data

保护共享的数据

 

    线程安全的程序需要开发人员在需要修改共享的数据时使用合适的锁机制。锁机制建立的

适合JMM的顺序，保证对于其他程序的可视性。

 当在同步机制外修改共享的data时，ＪＭＭ不能保证其一致性。 JVM提供了一些方法来保证其可视性。

 

Synchronized

 

   每一个对象实体都有一个监视器（来之于Object对象），这个监视器能被再某一线程中锁定。Synchronized关键字来指定在方法或者代码块上持有该对象监视器上的锁定。当某一线程同步修改一属性，后续线程将能看到被该线程修改的数据。

 

Lock

 

java.util.concurrent.locks 包提供了Lock的接口，ReentrantLock实现了类似Synchronized关键字的功能。同时还提供了额外的功能，比如不是阻塞的tryLock()方法和释放锁。

  

public class Counter {

private final Lock lock = new ReentrantLock();

private int value = 0;

public int increment() {

lock.lock();

try {

return ++value;

} finally {

lock.unlock();

}

}

}

 

同时，在多线程高冲突的情况下，ReentrantLock要比Synchronized效率好。

ReadWriteLock

 

java.util.concurrent.locks 包提供了一个读写锁的接口，这个接口定义了读和写的一对锁，

一般允许并行的读和排他的写。下面的代码展示了上述功能。

  

public class Statistic {

private final ReadWriteLock lock = new ReentrantReadWriteLock();

private int value;

public void increment() {

lock.writeLock().lock();

try {

value++;

} finally {

lock.writeLock().unlock();

}

}

public int current() {

lock.readLock().lock();

try {

return value;

} finally {

lock.readLock().unlock();

}

}

}

 

Volatile

 

Volatile 关键字使其属性对于后续的线程的可见性。

 

  

public class Processor implements Runnable {

private volatile boolean stop;

public void stopProcessing() {

stop = true;

}

public void run() {

while(! stop) {

// .. do processing

}

}

}

 

注意：将array标记为Volatile不能保证数组里面元素的Volatile，只能保证数组的引用时

可见的。使用AtomicIntegerArray 来保证整个数组都是可见的。

 

原子类

 

Volatile 的缺点是只能保证可见性。不能保证修改结果的可见性。而java.util.concurrent.atomic

包包含了一组支持原子操作的类来弥补Volatile的不足。

  

public class Counter {

private AtomicInteger value = new AtomicInteger();

public int next() {

return value.incrementAndGet();

}

}

 

ThreadLocal

     ThreadLocal存贮了该线程所需要的数据，不需要锁的机制。一般而言，ThreadLocal 存放当前的事务和其他资源等。如下代码，TransactionManager中，ThreadLocal  类型的currentTransaction 存贮了当前事务。


public class TransactionManager {

private static final ThreadLocal<Transaction> currentTransaction =

new ThreadLocal<Transaction>() {

@Override

protected Transaction initialValue() {

return new NullTransaction();

}

};

public Transaction currentTransaction() {

Transaction current = currentTransaction.get();

if(current.isNull()) {

current = new TransactionImpl();

currentTransaction.put(current);

}

return current;

}

}


并行容器

     合理维护共享数据一致性的核心技术是在访问数据时采取同步机制。这种技术使得所有访问共享数据的方式保证了同步的原则。java.util.concurrent提供了可以并行使用的数据结构。通常而言，使用这些数据结构优于通过Synchronized包装的非同步集合。

同步的 lists and sets

 

<
分享到：
| Jbpm4常见概念
评论
发表评论

您还没有登录,请您登录后再发表评论

相关推荐

    dnSpy-net-win32-222.zip

    dnSpy-net-win32-222.zip

    和美乡村城乡融合发展数字化解决方案.docx

    和美乡村城乡融合发展数字化解决方案.docx

    如何看待“适度宽松”的货币政策.pdf

    如何看待“适度宽松”的货币政策.pdf

    C#连接sap NCO组件 X64版

    NCO 3.0.18 64位

    法码滋.exe法码滋2.exe法码滋3.exe

    法码滋.exe法码滋2.exe法码滋3.exe

    基于MATLAB的导航科学计算库

    * GPS IMU经典15维ESKF松组合 * VRU/AHRS姿态融合算法 * 捷联惯导速度位置姿态解算例子 * UWB IMU紧组合融合 * 每个例子自带数据集

    毕业设计Jupyter Notebook基于深度网络的垃圾识别与分类算法研究项目源代码，用PyTorch框架中的transforms方法对数据进行预处理操作，后经过多次调参实验，对比不同模型分类效果

    在现代社会生活与生产活动下，不可避免的会产生巨量且多样的垃圾。我国的人口和经济总量均位居世界前列，因此，必然面临着庞大数量的垃圾处理的难题。如何通过人工智能来对垃圾进行有效分类，成为当前备受关注的研究热点。本文为展开基于深度网络的垃圾识别与分类算法研究，先使用PyTorch框架中的transforms方法对数据进行预处理操作，后经过多次调参实验，对比朴素贝叶斯模型、Keras卷积神经网络模型、ResNeXt101模型的垃圾分类效果。确定最佳分类模型是ResNeXt101，该模型在GPU环境下的分类准确率达到了94.7%。最后利用postman软件来测试API接口，完成图片的在线预测。在微信开发者工具的基础上，利用一些天行数据的垃圾分类的API接口再结合最佳模型的API接口，开发出了一个垃圾分类微信小程序。本文的研究内容丰富和完善了垃圾图像分类的相关研究，也为后续的研究提供了一定的参考价值。

    C#上位机开发与工控通讯实战课程

    一、上位机简介   在单片机项目开发中，上位机也是一个很重要的部分，主要用于数据显示（波形、温度等）、用户控制（LED，继电器等），下位机（单片机）与 上位机之间要进行数据通信的两种方式都是基于串口的： USB转串口 —— 上位机和下位机通过USB转串口连接线直接相连进行数据交互 串口转WIFI（ESP8266）—— 上位机和下位机基于TCP/IP协议通过以太网或者WIFI传输数据 串口转蓝牙（HC-06）—— 不多用，暂不介绍   Windows上位机（EXE可执行程序），最早用VB语言开发，后来由于C++的发展，采用MFC开发，近几年，微软发布了基于.NET框架的面向对象语言C#，更加稳定安全，再配合微软强大的VS进行开发，效率奇高。   本文使用Visual Studio 2022作为开发环境，上位机开发主要有WPF框架与Winform框架，他们都是基于.NET框架 WPF需要C/S基础，使用XAML来构建应用UI，界面比较美观，但是内存开销大 Winform可以使用窗口控件来构建应用，比较简单易学 二、开发环境设置 1. 安装Visual Studio 首先，确保你已经

    course_s4_ALINX_ZYNQ_MPSoC开发平台Linux驱动教程V1.04.pdf

    course_s4_ALINX_ZYNQ_MPSoC开发平台Linux驱动教程V1.04.pdf

    基于JavaWeb的毕业季旅游一站式定制服务平台_88z1j4jp_208-wx-(1).zip

    基于JavaWeb的毕业季旅游一站式定制服务平台_88z1j4jp_208-wx-(1).zip

    数据恢复软件 Apeaksoft Data Recovery for Mac v1.6.16

    Apeaksoft Data Recovery for Mac v1.6.16

    cms测试练习项目（linux系统部署）

    cms测试练习项目（linux系统部署），可以用来进行python的测试练手项目

    大学录取结果数据集，大学录取结果分析数据，大学录取因素分析

    数据集简介：大学录取结果分析 概述 大学录取结果数据集包含了有关大学录取过程的信息，包括关键变量，可用于分析不同学术因素与申请者是否被录取之间的关系。该数据集非常适合进行探索性数据分析、训练预测模型以及研究影响录取决策的因素。 数据集列描述 admit：指示申请者是否被录取（1=被录取，0=未录取）。 paes：申请者在高等教育能力测试（PAES）中获得的分数。 nem：中学教育成绩平均分，评分范围从1.0到7.0。 rank：申请者在其班级中的排名，数值越低表示排名越好。 数据集目的 本数据集旨在让用户探索学术指标（如PAES分数、GPA和排名）与大学录取成功率之间的关系。这可以用于： 开发预测模型：基于学术表现预测录取可能性。 识别趋势：找出影响录取的关键学术因素。 生成可视化图表：理解分数分布及录取结果的关系。 数据集规模 记录数：1813条。 列数：5列。

    STM32F427+rtthread下的bootload 网口(webclient)+串口(ymodem)传输，代码无质量，谨慎使用

    STM32F427+rtthread下的bootload 网口(webclient)+串口(ymodem)传输，代码无质量，谨慎使用

    电影院购票-JAVA-基于springBoot的电影院购票系统设计与实现（毕业论文）

    1. 用户管理功能 用户注册与登录：用户可以通过手机号、邮箱等方式注册账户，并且可以通过账号登录系统进行购票、查看历史订单等操作。 个人信息管理：用户可以查看和修改个人信息（如姓名、手机号、邮箱等），并进行密码重置等操作。 实名认证：部分电影院购票系统要求用户进行实名认证，确保用户身份的真实性。 2. 电影信息展示功能 电影排片查询：用户可以查看当前和未来一段时间内的电影排片表，包括电影名称、上映时间、影片时长、类型、导演、演员等详细信息。 电影详情页：点击具体电影后，用户可以查看电影的详细信息，如剧情介绍、影评、评分、预告片等内容。 电影评分与评论：用户可以查看其他观众的评分和评论，也可以对已观看的电影进行评分和评论。 3. 座位选择与预定功能 影厅座位图：系统展示每场次的影厅座位图，用户可以通过座位图查看当前座位的状态（如可选、已选、已售出、VIP座位等）。 座位选择：用户可以选择自己喜欢的座位，系统会实时更新座位的可用状态，避免重复选择。 座位偏好设置：用户可以设置自己的座位偏好，如选择前排、中排或后排，靠窗或靠过道等。 4. 电影票购买与支付功能 票价展示：系统会展示每个座位的

    Bukkit-BETA1.8.1服务端核心

    Bukkit-BETA1.8.1服务端核心

    快速排序在Go中的高效实现与应用

    内容概要：本文详细介绍了快速排序算法的原理和在Go语言中的高效实现方法。首先解释了快速排序的基本思想和实现步骤，接着提供了Go语言中实现快速排序的核心代码，并讨论了性能优化策略。最后，通过具体的应用场景实例，展示了快速排序在实际项目中的高效应用。 适合人群：具备一定编程基础，特别是对Go语言感兴趣的开发人员。 使用场景及目标：①理解快速排序算法的基本原理和分治策略；②学习如何在Go语言中高效实现快速排序；③掌握快速排序在实际项目中的应用实例。 阅读建议：本文不仅详细讲解了快速排序的原理，还提供了具体的实现代码和优化策略，建议读者在阅读过程中尝试实现和调试代码，以便更好地理解和掌握相关知识点。

    java毕设项目之学生社团管理系统+vue(完整前后端+说明文档+mysql+lw).zip

    项目包含完整前后端源码和数据库文件，均测试可正常运行 环境说明： 开发语言：Java 框架：ssm，mybatis JDK版本：JDK1.8 数据库：mysql 5.7 数据库工具：Navicat11 开发软件：eclipse/idea Maven包：Maven3.3 部署容器：tomcat7

    NSMethodNotImplementedException如何解决.md

    NSMethodNotImplementedException如何解决

    计算机接口实验报告.zip

    计算机接口实验报告，环境：PC 机一台，TD-PITE 实验装置一套。报告内容有，实验目的、实验设备、实验内容、实验步骤、实验程序（汇编）、实验结果、实验总结，一步到位！！！！！！ 一步到位！！！！！！

Magicbox
Global site tag (gtag.js) - Google Analytics

类

描述

CopyOnWriteArraySet

 

CopyOnWriteArraySet

提供Copy-On-Write的语义 即：每当修改某一数据时在整个容器内容拷贝上修改，然后将该备份同步入容器。

 

CopyOnWriteArrayList

 

类似CopyOnWriteArraySet

 

ConcurrentSkipListSet

 

JSE6提供的并行访问可以排序的Set。