- 浏览: 24449 次
- 性别:
- 来自: 上海
最新评论
1.同步与异步
1.1同步
在多线程的环境中,经常会碰到数据共享的情况,即当多个线程共同需要访问一个资源时,他们需要以某种顺序来确保该资源在某一时刻只能被一个线程使用,否则,程序的运行结果将是不可预料的,在这种情况下就必须对数据进行同步,例如多个线程同时对同一数据进行写操作,即当线程A需要使用某个资源时,如果这个资源正在被线程B使用,同步机制就会让线程A一直等待下去,直到线程B结束对该资源的使用后,线程A才能使用这个资源,由此可见,同步机制能够保证资源的安全。
要想实现同步操作,必须要获得每一个线程对象的锁。获得它可以保证在同一时刻只有一个线程能够进入临界区(访问互斥资源的代码块),并且在这个锁被释放前,其他线程就不能再进入这个临界区。如果还有其他线程想要获得该对象的锁,只能进入队列等待。只有当拥有该对象锁的线程退出临界区时,所才会被释放,等待队列中优先级最高的线程才能获得该锁,从而进入共享代码区。
2.多线程
实现java多线程的方法
(1)继承Thread类,重写run()方法
Thread本质上也是实现了Runnable接口的一个实例,他代表一个线程的实例,并且,启动线程的唯一方法就是通过Thread类的start()方法。start()方法是一个本地方法,他将启动一个新线程,并执行 run()方法(只有通过start()方法调用的run()方法才能真正的起到异步的作用)。
**小提示**start()方法被调用后并不是立刻执行多线程的代码,而是使得该线程变为可运行状态,什么时候运行多线程代码是由操作系统决定的。(就绪,运行,挂起,结束)
(2)实现Runnable接口,实现run()方法。
小提示创建Thread对象,用事先Runnable接口的对象作为参数实例化改Thread对象。
实现Callable接口,重写call()方法。(这个不是重点不建议使用)
3.多线程同步
多线程同步的方法有哪些?
(1)synchronized关键字
在java中,每个对象都有一个对象锁与之相关联,该锁表明对象在任何时候只允许被一个线程所拥有,当一个线程调用对象的一段synchronized代码时,首先要获取这个锁,然后执行相应的代码,执行结束,释放锁。
synchronized关键字主要有两种用法:
1.synchronized申明方法:public synchronized void xxx();
2.synchronized代码块:synchronized(obj){}
(2)wait()方法和notify()方法
wait()方法表示放弃当前对资源的占有权并且释放对象锁进入等待状态,一直到有人通知。
notify()方法表示当前的线程已经放弃对资源的占有,通知等待的线程来获得对资源的占有权。然后运行wait()后面的语句。被唤醒的线程依旧阻塞在wait()中直到获得对象的锁
重点内容:notify()方法放弃对资源的占用但是并没有释放对象锁
notify()和wait()方法需要配合synchronized关键字使用。
**“`
public class Consumer implements Runnable {
@Override
public synchronized void run() {
// TODO Auto-generated method stub
int count = 10;
while(count > 0) {
synchronized (Test. obj) {
System. out.print( "B");
count --;
Test. obj.notify(); // 主动释放对象资源
try {
Test. obj.wait();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}
}
public class Produce implements Runnable {
@Override
public void run() {
// TODO Auto-generated method stub
int count = 10;
while(count > 0) {
synchronized (Test. obj) {
//System.out.print("count = " + count);
System. out.print( "A");
count --;
Test. obj.notify();
try {
Test. obj.wait();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}
}
测试类如下:
public class Test {
public static final Object obj = new Object();
public static void main(String[] args) {
new Thread( new Produce()).start();
new Thread( new Consumer()).start();
}
}
“`**
(3)Lock
a.lock():以阻塞的方式获取锁,也就是说如果获得锁,立刻返回;如果别的线程持有锁,当前线程等待,知道获取锁后返回。
b.tryLock():以非阻塞的方式获取锁。只是尝试性的去获取锁,如果取得则返回true,否则,立刻返回false。
c.tryLock(long timeout,TimeUnit unit):如果获取了锁,立刻返回true,否则会等待参数给定的时间单元,在等待的过程中,如果获取了锁,就立刻返回true,如果等待超时,返回false。
d.lockInterruptibly():如果获取了锁,立刻返回。否则当前线程处于休眠状态,直到获得锁,或者当前线程被别的线程中断。他与lock()方法最大的区别在于如果lock()方法获取不到锁,会一直处于阻塞状态,且会忽略interrupt()方法。
**`除了wait()和notify()协作完成线程同步之外,使用Lock也可以完成同样的目的。
ReentrantLock 与synchronized有相同的并发性和内存语义,还包含了中断锁等候和定时锁等候,意味着线程A如果先获得了对象obj的锁,那么线程B可以在等待指定时间内依然无法获取锁,那么就会自动放弃该锁。
但是由于synchronized是在JVM层面实现的,因此系统可以监控锁的释放与否,而ReentrantLock使用代码实现的,系统无法自动释放锁,需要在代码中finally子句中显式释放锁lock.unlock();
同样的例子,使用lock 如何实现呢?
public class Consumer implements Runnable {
private Lock lock;
public Consumer(Lock lock) {
this. lock = lock;
}
@Override
public void run() {
// TODO Auto-generated method stub
int count = 10;
while( count > 0 ) {
try {
lock.lock();
count --;
System. out.print( "B");
} finally {
lock.unlock(); //主动释放锁
try {
Thread. sleep(91L);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}
}
public class Producer implements Runnable{
private Lock lock;
public Producer(Lock lock) {
this. lock = lock;
}
@Override
public void run() {
// TODO Auto-generated method stub
int count = 10;
while (count > 0) {
try {
lock.lock();
count --;
System. out.print( "A");
} finally {
lock.unlock();
try {
Thread. sleep(90L);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}
}
调用代码:
public class Test {
public static void main(String[] args) {
Lock lock = new ReentrantLock();
Consumer consumer = new Consumer(lock);
Producer producer = new Producer(lock);
new Thread(consumer).start();
new Thread( producer).start();
}
}
使用建议:
在并发量比较小的情况下,使用synchronized是个不错的选择,但是在并发量比较高的情况下,其性能下降很严重,此时ReentrantLock是个不错的方案。`**
4.并发与并行
并发:单个处理器,轮换执行多个任务,看起来好像是多个任务同时在执行一样。
并行:多个处理器,同时执行多个任务,但是每个任务分配在一个cpu上执行。
1.1同步
在多线程的环境中,经常会碰到数据共享的情况,即当多个线程共同需要访问一个资源时,他们需要以某种顺序来确保该资源在某一时刻只能被一个线程使用,否则,程序的运行结果将是不可预料的,在这种情况下就必须对数据进行同步,例如多个线程同时对同一数据进行写操作,即当线程A需要使用某个资源时,如果这个资源正在被线程B使用,同步机制就会让线程A一直等待下去,直到线程B结束对该资源的使用后,线程A才能使用这个资源,由此可见,同步机制能够保证资源的安全。
要想实现同步操作,必须要获得每一个线程对象的锁。获得它可以保证在同一时刻只有一个线程能够进入临界区(访问互斥资源的代码块),并且在这个锁被释放前,其他线程就不能再进入这个临界区。如果还有其他线程想要获得该对象的锁,只能进入队列等待。只有当拥有该对象锁的线程退出临界区时,所才会被释放,等待队列中优先级最高的线程才能获得该锁,从而进入共享代码区。
2.多线程
实现java多线程的方法
(1)继承Thread类,重写run()方法
Thread本质上也是实现了Runnable接口的一个实例,他代表一个线程的实例,并且,启动线程的唯一方法就是通过Thread类的start()方法。start()方法是一个本地方法,他将启动一个新线程,并执行 run()方法(只有通过start()方法调用的run()方法才能真正的起到异步的作用)。
**小提示**start()方法被调用后并不是立刻执行多线程的代码,而是使得该线程变为可运行状态,什么时候运行多线程代码是由操作系统决定的。(就绪,运行,挂起,结束)
(2)实现Runnable接口,实现run()方法。
小提示创建Thread对象,用事先Runnable接口的对象作为参数实例化改Thread对象。
实现Callable接口,重写call()方法。(这个不是重点不建议使用)
3.多线程同步
多线程同步的方法有哪些?
(1)synchronized关键字
在java中,每个对象都有一个对象锁与之相关联,该锁表明对象在任何时候只允许被一个线程所拥有,当一个线程调用对象的一段synchronized代码时,首先要获取这个锁,然后执行相应的代码,执行结束,释放锁。
synchronized关键字主要有两种用法:
1.synchronized申明方法:public synchronized void xxx();
2.synchronized代码块:synchronized(obj){}
(2)wait()方法和notify()方法
wait()方法表示放弃当前对资源的占有权并且释放对象锁进入等待状态,一直到有人通知。
notify()方法表示当前的线程已经放弃对资源的占有,通知等待的线程来获得对资源的占有权。然后运行wait()后面的语句。被唤醒的线程依旧阻塞在wait()中直到获得对象的锁
重点内容:notify()方法放弃对资源的占用但是并没有释放对象锁
notify()和wait()方法需要配合synchronized关键字使用。
**“`
public class Consumer implements Runnable {
@Override
public synchronized void run() {
// TODO Auto-generated method stub
int count = 10;
while(count > 0) {
synchronized (Test. obj) {
System. out.print( "B");
count --;
Test. obj.notify(); // 主动释放对象资源
try {
Test. obj.wait();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}
}
public class Produce implements Runnable {
@Override
public void run() {
// TODO Auto-generated method stub
int count = 10;
while(count > 0) {
synchronized (Test. obj) {
//System.out.print("count = " + count);
System. out.print( "A");
count --;
Test. obj.notify();
try {
Test. obj.wait();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}
}
测试类如下:
public class Test {
public static final Object obj = new Object();
public static void main(String[] args) {
new Thread( new Produce()).start();
new Thread( new Consumer()).start();
}
}
“`**
(3)Lock
a.lock():以阻塞的方式获取锁,也就是说如果获得锁,立刻返回;如果别的线程持有锁,当前线程等待,知道获取锁后返回。
b.tryLock():以非阻塞的方式获取锁。只是尝试性的去获取锁,如果取得则返回true,否则,立刻返回false。
c.tryLock(long timeout,TimeUnit unit):如果获取了锁,立刻返回true,否则会等待参数给定的时间单元,在等待的过程中,如果获取了锁,就立刻返回true,如果等待超时,返回false。
d.lockInterruptibly():如果获取了锁,立刻返回。否则当前线程处于休眠状态,直到获得锁,或者当前线程被别的线程中断。他与lock()方法最大的区别在于如果lock()方法获取不到锁,会一直处于阻塞状态,且会忽略interrupt()方法。
**`除了wait()和notify()协作完成线程同步之外,使用Lock也可以完成同样的目的。
ReentrantLock 与synchronized有相同的并发性和内存语义,还包含了中断锁等候和定时锁等候,意味着线程A如果先获得了对象obj的锁,那么线程B可以在等待指定时间内依然无法获取锁,那么就会自动放弃该锁。
但是由于synchronized是在JVM层面实现的,因此系统可以监控锁的释放与否,而ReentrantLock使用代码实现的,系统无法自动释放锁,需要在代码中finally子句中显式释放锁lock.unlock();
同样的例子,使用lock 如何实现呢?
public class Consumer implements Runnable {
private Lock lock;
public Consumer(Lock lock) {
this. lock = lock;
}
@Override
public void run() {
// TODO Auto-generated method stub
int count = 10;
while( count > 0 ) {
try {
lock.lock();
count --;
System. out.print( "B");
} finally {
lock.unlock(); //主动释放锁
try {
Thread. sleep(91L);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}
}
public class Producer implements Runnable{
private Lock lock;
public Producer(Lock lock) {
this. lock = lock;
}
@Override
public void run() {
// TODO Auto-generated method stub
int count = 10;
while (count > 0) {
try {
lock.lock();
count --;
System. out.print( "A");
} finally {
lock.unlock();
try {
Thread. sleep(90L);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}
}
调用代码:
public class Test {
public static void main(String[] args) {
Lock lock = new ReentrantLock();
Consumer consumer = new Consumer(lock);
Producer producer = new Producer(lock);
new Thread(consumer).start();
new Thread( producer).start();
}
}
使用建议:
在并发量比较小的情况下,使用synchronized是个不错的选择,但是在并发量比较高的情况下,其性能下降很严重,此时ReentrantLock是个不错的方案。`**
4.并发与并行
并发:单个处理器,轮换执行多个任务,看起来好像是多个任务同时在执行一样。
并行:多个处理器,同时执行多个任务,但是每个任务分配在一个cpu上执行。
发表评论
-
流式数据、批式数据、实时数据、历史数据的区别
2018-05-31 17:00 2021大数据处理系统可分为批式(batch)大数据和流式(s ... -
网络协议
2018-05-29 16:38 442一、基本概念 1、TCP连 ... -
HTTP状态码说明
2018-05-13 11:50 790HTTP状态码(HTTP Status Code)是用以表示 ... -
Spring常用注解汇总
2018-05-13 11:18 613Spring的常用注解,具体如下: 使用注解之前要开启自动 ... -
URL地址中中文乱码详解
2018-05-07 10:43 1310引言: 在Restful类的服务设计中,经常会碰到需要在URL ... -
javaScript字符串编码
2018-05-07 10:39 495javaScript中中有有三个可以对字符串编码的函数,分别是 ... -
jvm内存模型
2018-05-05 21:18 398jvm内存模型: 栈(stake):每个线程都有私有栈内存 主 ... -
常用编码总结
2018-05-05 19:59 4341.编码区别: iso8859-1: 通常叫做Latin-1, ... -
JVM设置
2018-04-18 10:00 3811、Eclise 中设置jvm内存: 修改eclipse的配置 ... -
java移动文件并编辑文件内容
2018-03-27 18:15 418package com.wonders.utils; i ... -
log4j(转:https://www.cnblogs.com/crazyacking/p/5456347.html)
2018-02-23 09:50 435log4j需要导入的包 添加配置文件 建立类文件+主函数 修改 ... -
部署多个tomcat
2017-07-20 20:56 312下面我们把配置的详细过程写在下面,以供参考:(此例以配置三 ... -
web.xml常用标签(转)
2016-11-07 22:19 444web.xml文件是用来初始化配置信息:比如welcome页面 ... -
网页顶部空几行 jsp(转)
2016-10-10 19:52 339jsp中会经常使用到使用jsp标签和jstl的标签,比如< ... -
Java的图片处理工具类(转)
2016-10-17 19:59 533//可实现以下常用功能:缩放图像、切割图像、图像类型转换、彩色 ... -
mybatis的oracle分页查询demo
2016-10-08 20:59 1015<!-- mybatis oracle分页查询 -- ... -
关于自己遇到hibernate主键策略bug
2016-10-08 20:53 280hibernate主键策略,若为sequence,主键 ... -
解压版Tomcat配置(本例Tomcat6)
2015-10-16 10:22 444一 配置Tomcat 1 下载Tomcat Zip压缩包,解压 ... -
myeclipse搭建struts项目
2015-09-28 16:54 359一、创建web project项目; 二、选 ... -
异常:Project configuration is not up-to-date with pom.xml解决方案
2015-09-24 09:13 779[size=xx-large][/size]导入maven工程 ...
相关推荐
并发、多线程、同步异步概念的介绍。。。
Python3爬虫系列的理论验证,比较同步依序下载、多进程并发、多线程并发和asyncio异步编程之间的效率差别
java多线程并发查询数据库,使用线程池控制分页,并发查询。
Java-多线程异步请求统一响应结果 多线程异步请求是指在多个线程同时发起请求,并且在请求过程中不阻塞主线程的执行。这样可以提高程序的并发能力和响应速度。 需要注意的是,在实际的异步请求中,可能需要使用...
Java多线程实现数据切割批量执行,实现限流操作。 java线程池Executors实现数据批量操作。 批量异步Executors处理数据,实现限流操作,QPS限流。 线程池调用第三方接口限流实现逻辑。 案例适合: 1.批量处理大数据。...
socket多线程并发异步通讯 1、多客户端; 2、高并发连接断开; 3、高并发异步接收发送; 4、无丢包;
利用线程完成高并发,异步处理大数据,同时可以做到削峰,是大数据处理和高并发控制很好的干货,欢迎需要的朋友点击下载
此外,本书还提供了有关并发编程的全方位的详细内容,例如限制和同步、死锁和冲突、依赖于状态的操作控制、异步消息传递和控制流、协作交互,以及如何创建基于web的服务和计算型服务。 本书的读者对象是那些希望掌握...
支持多线程并发与消息异步处理的Linux Netlink通信机制研究.pdf
(注意,本资源附带书中源代码可供参考) 多线程与并发处理是程序设计好坏优劣的重要课题,本书通过浅显易懂的文字与实例来介绍Java线程相关的设计模式概念,并且通过实际的Java程序范例和 UML图示来一一解说,书中...
随着拥有多个硬线程 CPU(超线程、双核)的普及,多线程和异步操作等并发程序设计方法也受到了更多的关注和讨论。本文主要是想与各位高手一同探讨一下如何使用并发来最大化程序的性能。 多线程和异步操作的异同 多...
3. 同步和异步有何异同,在什么情况下分别使用他们? 4. 当一个线程进入一个对象的一个 synchronized 方法后,其它线程是否可进入此对象的其它方法? 5. 简述 synchronized 和 java.util.concurrent.locks.Lock 的...
DougLee可扩展的网络服务事件驱动Reactor模式基础版多线程版其他变体java.io包中分阻塞IOAPI一览Web服务器,分布式对象系统等等它们的共同特点Read请求解码请求报文业务处理编码响应报文发送响应实际应用中每一个...
本书是一本通俗易懂的C#多线程编程指南,通过70多个容易理解的示例,循序渐进地讲解C#5.0中的异步及并发编程,引导读者了解Windows下C#多线程编程的多样性。 通过阅读本书,你将学到: 使用原始线程、异步线程,...
android异步加载图片,升级版,添加多线程并发控制,可设置并发请求线程数量
4.4 在现有的线程安全类中添加功能 4.4.1 客户端加锁机制 4.4.2 组合 4.5 将同步策略文档化 第5章 基础构建模块 5.1 同步容器类 5.1.1 同步容器类的问题 5.1.2 迭代器与Concurrent-ModificationException ...
专注于类型安全、并发和多线程的,快速 、专业的Swift异步任务库️
随着拥有多个硬线程CPU(超线程、双核)的普及,多线程和异步操作等并发程序设计方法也受到了更多的关注和讨论。本文主要是想与园中各位高手一同探讨一下如何使用并发来最大化程序的性能
该文档旨在介绍基于MVC的架构开发时的线程及并发的使用方式及常用的案例,供大家学习。 对于Web开发,我想本文的知识点应该足够,如果后面有遇到本文没讲的,后面再补充吧。