java并发编程实例分析
java并发编程是java程序设计语言的一块重点,在大部分的业务场景中都需要并发编程。
比如:并发的去处理http请求,这样就可以使得一台机器同时处理多个请求,大大提高业务的响应效率,从而使用用户体验更加流畅。
java如何并发编程,要注意以下几个方面:
1、java语言中的多线程操作:创建和启动线程的几种方式。
2、共享变量的同步问题,要保证线程安全,辨别哪些变量是线程安全的、那些变量是线程不安全的,对于不安全的变量我们要想办法让其同步,一般也就是加锁。
3、线程锁:包括方法锁和synchronized块的使用。
接下来就详细说一下这几个方面。
首先说创建线程的方式:一般有两种方式
定义一个线程类:实现Runnable接口、或者继承Thread,推荐是实现接口的方式。
启动线程的方式:
第一种:new Thread()的方式。
创建好的线程,然后通过new的方式启动线程,因为创建方式的不同,他们启动的方式也略微有些差别。
第二种:通过线程池的方式启动线程。JavaAPI提供了线程池技术,可以用池的原理,
去管理线程,池的技术在java中很常见,比如数据库连接池等。
具体细节可以参考如下的连接:
共享变量的问题:要明白什么变量最有可能出现线程安全问题。没错就是静态变量,静态变量
相当于C语言的全局变量,如果是public类型,谁都可以修改,所以这个时候就会出现
变量的线程安全问题。当然了私有变量也可能出现线程安全问题。
具体细节可以参考如下的连接:
主要来说一下线程锁的两种方式:
(1)首先定义一个MyBusiness类,此类中顶一个一个静态变量i,和一个静态方法,静态方法的功能是让i加1。
(2)然后定义一个线程类MyThread2,run方法中先让线程sleep 2毫秒,然后执行加1操作。
(3)定义测试类,测试类创建6000个MyThread2线程,然后sleep 1秒钟,执行输出,显示i的值。
(4)结果:从结果可以看出,此时出现了线程安全问题,就是说某些线程在加1操作时取到了脏数据,即
在某一个时间点,多个线程同时取到了某个相同的i值,然后去修改,结果导致在这几个线程中,只有最后一个
修改生效,而其他的则被覆盖掉了。
(5)解决方案一:方法锁,给add方法加锁,表示同一时间只能有一个方法的调用被允许运行,其他的线程等待锁的释放。
再次运行,发现变成了6000就是正确的了。
(6)解决方案二:synchronized代码块,我们重新定义一个方法add1,然后用synchronized代码块锁上MyBusiness类,
表示同一时间只能有一个线程操作MyBusiness类,其他线程必须等待锁的释放。
(7)查看结果,也得到了正确的输出。
相关推荐
-
Java并发编程学习之Unsafe类与LockSupport类源码详析
一.Unsafe类的源码分析 JDK的rt.jar包中的Unsafe类提供了硬件级别的原子操作,Unsafe里面的方法都是native方法,通过使用JNI的方式来访问本地C++实现库. rt.jar 中 Unsafe 类主要函数讲解, Unsafe 类提供了硬件级别的原子操作,可以安全的直接操作内存变量,其在 JUC 源码中被广泛的使用,了解其原理为研究 JUC 源码奠定了基础. 首先我们先了解Unsafe类中主要方法的使用,如下: 1.long objectFieldOffset(Field
-
Java并发编程this逃逸问题总结
this逃逸是指在构造函数返回之前其他线程就持有该对象的引用. 调用尚未构造完全的对象的方法可能引发令人疑惑的错误, 因此应该避免this逃逸的发生. this逃逸经常发生在构造函数中启动线程或注册监听器时, 如: public class ThisEscape { public ThisEscape() { new Thread(new EscapeRunnable()).start(); // ... } private class EscapeRunnable implements Run
-
Java并发编程Callable与Future的应用实例代码
本文主要探究的是java并发编程callable与future的使用,分享了相关实例代码,具体介绍如下. 我们都知道实现多线程有2种方式,一种是继承Thread,一种是实现Runnable,但这2种方式都有一个缺陷,在任务完成后无法获取返回结果.要想获得返回结果,就得使用Callable,Callable任务可以有返回值,但是没法直接从Callable任务里获取返回值:想要获取Callabel任务的返回值,需要用到Future.所以Callable任务和Future模式,通常结合起来使用. 试想
-
Java并发编程包中atomic的实现原理示例详解
线程安全: 当多个线程访问某个类时,不管运行时环境采用何种调度方式或者这些进程将如何交替执行,并且在主调代码中不需要任何额外的同步或协调,这个类都能表现出正确的行为,那么就称这个类时线程安全的. 线程安全主要体现在以下三个方面: 原子性:提供了互斥访问,同一时刻只能有一个线程对它进行操作 可见性:一个线程对主内存的修改可以及时的被其他线程观察到 有序性:一个线程观察其他线程中的指令执行顺序,由于指令重排序的存在,该观察结果一般杂乱无序 引子 在多线程的场景中,我们需要保证数据安全,就会考虑同步的
-
Java并发编程学习之ThreadLocal源码详析
前言 多线程的线程安全问题是微妙而且出乎意料的,因为在没有进行适当同步的情况下多线程中各个操作的顺序是不可预期的,多线程访问同一个共享变量特别容易出现并发问题,特别是多个线程需要对一个共享变量进行写入时候,为了保证线程安全, 一般需要使用者在访问共享变量的时候进行适当的同步,如下图所示: 可以看到同步的措施一般是加锁,这就需要使用者对锁也要有一定了解,这显然加重了使用者的负担.那么有没有一种方式当创建一个变量的时候,每个线程对其进行访问的时候访问的是自己线程的变量呢?其实ThreaLocal就可
-
java编程多线程并发处理实例解析
本文主要是通过一个银行用户取钱的实例,演示java编程多线程并发处理场景,具体如下. 从一个例子入手:实现一个银行账户取钱场景的实例代码. 第一个类:Account.java 账户类: package cn.edu.byr.test; public class Account { private String accountNo; private double balance; public Account(){ } public Account(String accountNo,double
-
java并发编程实例分析
java并发编程是java程序设计语言的一块重点,在大部分的业务场景中都需要并发编程. 比如:并发的去处理http请求,这样就可以使得一台机器同时处理多个请求,大大提高业务的响应效率,从而使用用户体验更加流畅. java如何并发编程,要注意以下几个方面: 1.java语言中的多线程操作:创建和启动线程的几种方式. 2.共享变量的同步问题,要保证线程安全,辨别哪些变量是线程安全的.那些变量是线程不安全的,对于不安全的变量我们要想办法让其同步,一般也就是加锁. 3.线程锁:包括方法锁和synchro
-
ZooKeeper Java API编程实例分析
本实例我们用的是java3.4.6版本,实例方便大家学习完后有不明白的可以在留言区讨论. 开发应用程序的ZooKeeper Java绑定主要由两个Java包组成: org.apache.zookeeper org.apache.zookeeper.data org.apache.zookeeper包由ZooKeeper监视的接口定义和ZooKeeper的各种回调处理程序组成. 它定义了ZooKeeper客户端类库的主要类以及许多ZooKeeper事件类型和状态的静态定义. org.apache.
-
Java并发编程:CountDownLatch与CyclicBarrier和Semaphore的实例详解
Java并发编程:CountDownLatch与CyclicBarrier和Semaphore的实例详解 在java 1.5中,提供了一些非常有用的辅助类来帮助我们进行并发编程,比如CountDownLatch,CyclicBarrier和Semaphore,今天我们就来学习一下这三个辅助类的用法. 以下是本文目录大纲: 一.CountDownLatch用法 二.CyclicBarrier用法 三.Semaphore用法 若有不正之处请多多谅解,并欢迎批评指正. 一.CountDownLatch
-
Java并发编程(CyclicBarrier)实例详解
Java并发编程(CyclicBarrier)实例详解 前言: 使用JAVA编写并发程序的时候,我们需要仔细去思考一下并发流程的控制,如何让各个线程之间协作完成某项工作.有时候,我们启动N个线程去做一件事情,只有当这N个线程都达到某一个临界点的时候,我们才能继续下面的工作,就是说如果这N个线程中的某一个线程先到达预先定义好的临界点,它必须等待其他N-1线程也到达这个临界点,接下来的工作才能继续,只要这N个线程中有1个线程没有到达所谓的临界点,其他线程就算抢先到达了临界点,也只能等待,只有所有这N
-
Java并发编程之常用的多线程实现方式分析
本文实例讲述了Java并发编程之常用的多线程实现方式.分享给大家供大家参考,具体如下: 概述 常用的多线程实现方式有2种: 1. 继承Thread类 2. 实现Runnable接口 之所以说是常用的,是因为通过还可以通过JUC(java.util.concurrent)包中的线程池来实现多线程.关于线程池的内容,我们以后会详细介绍:现在,先对的Thread和Runnable进行了解. Thread简介 Thread 是一个类.Thread本身就实现了Runnable接口.它的声明如下: publ
-
java并发编程专题(八)----(JUC)实例讲解CountDownLatch
CountDownLatch 是一个非常实用的多线程控制工具类." Count Down " 在英文中意为倒计数, Latch 为门问的意思.如果翻译成为倒计数门阀, 我想大家都会觉得不知所云吧! 因此,这里简单地称之为倒计数器.在这里, 门问的含义是:把门锁起来,不让里面的线程跑出来.因此,这个工具通常用来控制线程等待,它可以让某一个线程等待直到倒计时结束, 再开始执行. CountDown Latch 的构造函数接收一个整数作为参数,即当前这个计数器的计数个数. public Co
-
分析Java并发编程之信号量Semaphore
目录 一.认识Semaphore 1.1.Semaphore 的使用场景 1.2.Semaphore 使用 1.3.Semaphore 信号量的模型 二.Semaphore 深入理解 2.1.Semaphore 基本属性 2.2.Semaphore 的公平性和非公平性 2.3.其他 Semaphore 方法 一.认识Semaphore 1.1.Semaphore 的使用场景 Semaphore 的使用场景主要用于流量控制,比如数据库连接,同时使用的数据库连接会有数量限制,数据库连接不能超过一定的
-
java并发编程Lock锁可重入性与公平性分析
目录 一.相似之处:Lock锁 vs Synchronized 代码块 二.Lock接口中的方法 三.不同点:Lock锁 vs Synchronized 代码块 四.锁的可重入性 4.1. synchronized锁的可重入性 4.2.ReentrantLock可重入锁 五.Lock锁的公平性 一.相似之处:Lock锁 vs Synchronized 代码块 Lock锁是一种类似于synchronized 同步代码块的线程同步机制.从Java 5开始java.util.concurrent.lo
-
Java 并发编程:volatile的使用及其原理解析
Java并发编程系列[未完]: •Java 并发编程:核心理论 •Java并发编程:Synchronized及其实现原理 •Java并发编程:Synchronized底层优化(轻量级锁.偏向锁) •Java 并发编程:线程间的协作(wait/notify/sleep/yield/join) •Java 并发编程:volatile的使用及其原理 一.volatile的作用 在<Java并发编程:核心理论>一文中,我们已经提到过可见性.有序性及原子性问题,通常情况下我们可以通过Synchroniz
随机推荐
- Android常用正则表达式验证工具类(实例代码)
- javascript秒数倒计时自动跳转代码
- Java绘图技术的详解及实例
- 通过RadioButton对DataList控件进行单选实例说明
- php smarty模版引擎中变量操作符及使用方法
- 深入解析PHP垃圾回收机制对内存泄露的处理
- PHP实现将多个文件中的内容合并为新文件的方法示例
- php cc攻击代码与防范方法
- 动网论坛验证码改进 加法验证码(ASPJpeg版)
- c++回调之利用函数指针示例
- Docker 教程之镜像创建及修改详细介绍
- php5.3 废弃函数小结
- JS文件上传神器bootstrap fileinput详解
- MySQL入门教程(五)之表的创建、修改和删除
- jQuery异步提交表单的两种方式
- jQuery EasyUI API 中文文档 - ProgressBar 进度条
- C#自定义字符串替换Replace方法实例
- 详解Android的反编译和代码混淆
- VMware虚拟机nat模式连不上网的解决方法
- 微信小程序canvas实现刮刮乐效果