Android多线程之同步锁的使用

本文主要介绍了Android多线程之同步锁的使用，分享给大家，具体如下：

一、同步机制关键字synchronized

对于Java来说，最常用的同步机制就是synchronized关键字，他是一种基于语言的粗略锁，能够作用于对象、函数、class。每个对象都只有一个锁，谁能够拿到这个锁谁就有访问权限。当synchronized作用于函数时，实际上锁的也是对象，锁定的对象就是该函数所在类的对象。而synchronized作用于class时则是锁的这个Class类，并非具体对象。

public class SynchronizedClass {

public synchronized void syncMethod(){

//代码

}

public void syncThis(){

synchronized (this){

//代码

}

public void syncClassMethod(){

synchronized (SynchronizedClass.class){

//代码

}

public synchronized static void syncStaticMethod(){

//代码

}

上面演示了同步方法、同步块、同步class对象、同步静态方法。前2种锁的是对象，而后两种锁的是class对象。对于class对象来说，它的作用是防止多个线程同时访问添加了synchronized锁的代码块，而synchronized作用于引用对象是防止其他线程访问同一个对象中synchronized代码块或者函数。

二、显示锁———-ReentrankLock和Condition

ReentrankLock 和内置锁synchronized相比，实现了相同的语义，但是更具有更高的灵活性。

(1)获得和释放的灵活性。
(2)轮训锁和定时锁。
(3)公平性。

基本操作:

lock(): 获取锁

tryLock(): 尝试获取锁

tryLock(long timeout,TimeUnit unit): 尝试获取锁，如果到了指定的时间还获取不到，那么超时。

unlock(): 释放锁

newCondition(): 获取锁的 Condition

使用ReentrantLock的一般组合是 lock、tryLock、与unLock成对出现，需要注意的是，千万不要忘记调用unlock来释放锁，负责可能引发死锁的问题。ReentrantLock的常用形式如下所示:

public class ReentrantLockDemo {

Lock lock = new ReentrantLock();

public void doSth(){

lock.lock();

try {

//执行某些操作

}finally {

lock.unlock();

}

需要注意的是，lock必须在finally开中释放，否则，如果受保护的代码抛出异常，锁就可能永远得不到释放！！

ReentrantLock类中还有一个重要的函数newCondition(),该函数用户获取Lock()上的一个条件，也就是说Condition与Lock绑定。Condition用于实现线程间的通信，他是为了解决Object.wait(),nofity(),nofityAll() 难以使用的问题。
Condition的方法如下:

await() : 线程等待

await(int time,TimeUnit unit) 线程等待特定的时间，超过的时间则为超时。

signal() 随机唤醒某个等待线程

signal() 唤醒所有等待中的线程

示例代码:

public class MyArrayBlockingQueue<T> {

// 数据数组

private final T[] items;

private final Lock lock = new ReentrantLock();

private Condition notFull = lock.newCondition();

private Condition notEmpty = lock.newCondition() ;

// 头部索引

private int head;

// 尾部索引

private int tail ;

// 数据的个数

private int count;

public MyArrayBlockingQueue(int maxSize) {

items = (T[]) new Object[maxSize];

}

public MyArrayBlockingQueue(){

this(10);

}

public void put(T t){

lock.lock();

try {

while(count == getCapacity()){

System.out.println("数据已满，等待");

notFull.await();

}

items[tail] =t ;

if(++tail ==getCapacity()){

tail = 0;

}

++count;

notEmpty.signalAll();//唤醒等待数据的线程

} catch (InterruptedException e) {

e.printStackTrace();

}finally {

lock.unlock();

}

public int getCapacity(){

return items.length ;

}

public T take(){

lock.lock();

try {

while(count ==0){

System.out.println("还没有数据，等待");

//哪个线程调用await()则阻塞哪个线程

notEmpty.await();

}

T ret = items[head];

items[head] = null ;

if(++head == getCapacity()){

head =0 ;

}

--count;

notFull.signalAll();

return ret ;

} catch (InterruptedException e) {

e.printStackTrace();

}finally {

lock.unlock();

}

return null ;

}

public int size(){

lock.lock();

try {

return count;

}finally {

lock.unlock();

}

public static void main(String[] args){

MyArrayBlockingQueue<Integer> aQueue = new MyArrayBlockingQueue<>();

aQueue.put(3);

aQueue.put(24);

for(int i=0;i<5;i++){

System.out.println(aQueue.take());

}

System.out.println("结束");

}

执行结果:

3
24
还没有数据，等待

三、信号量 Semaphore

Semaphore是一个计数信号量，它的本质是一个“共享锁”。信号量维护了一个信号量许可集，线程可以通过调用acquire()来获取信号量的许可。当信号量中有可用的许可时，线程能获取该许可；否则线程必须等待，直到可用的许可为止。线程可以通过release()来释放它所持有的信号量许可。

示例:

public class SemaphoreTest {

public static void main(String[] args){

final ExecutorService executorService = Executors.newFixedThreadPool(3);

final Semaphore semaphore = new Semaphore(3);

List<Future> futures = new ArrayList<>();

for (int i = 0; i < 5; i++) {

Future<?> submit = executorService.submit(new Runnable() {

@Override

public void run() {

try {

semaphore.acquire();

System.out.println(" 剩余许可: " + semaphore.availablePermits());

Thread.sleep(3000);

semaphore.release();

} catch (InterruptedException e) {

e.printStackTrace();

}

});

futures.add(submit);

}

以上就是本文的全部内容，希望对大家的学习有所帮助

Android多线程之同步锁的使用相关推荐

Java基础知识多线程，同步锁
多线程 /*多线程: 多任务执行,多路径执行优点:提高性能提高效率进程与线程之间的区别:进程 : 系统中的程序,一个进程之间可以包含1~n个线程,系统中资源分配的最小单位,每个进程都有自己的代码与数据 ...
Python 的多线程(1) - 同步锁
前言 : 最近对Python赶感兴趣了, 原因是公司需求对接第三方的业务比较多,所以寻找测试资源很麻烦,每天都在各种做重复的工作. 所以就想到了用python写个小脚本来找, 为什么是Python,主 ...
python 多线程同步锁之实现停车场业务(2)
这边文章是实现同时有车辆出去,又有车辆进来的业务逻辑,和现实的差不多真正要和现实中的一样,只需要更改休眠时间就可,通过调节修改时间,动态实现之前的代码 python 多线程同步锁之实现停车场业务( ...
Java多线程系列---“JUC锁”01之框架
本章,我们介绍锁的架构:后面的章节将会对它们逐个进行分析介绍.目录如下: 01. Java多线程系列--"JUC锁"01之框架 02. Java多线程系列--"JUC锁 ...
Android 多线程保证操作同步(同步锁的俩种)
今天来介绍一下android中多线程同步的机制首先我们来创建几个多线程,模仿一下文件读写的操作. private void writeLog() {for (int i = 0; i < 3; ...
android 多线程实现方式、并发与同步学习总结
参考地址:http://blog.csdn.net/qq_30379689/article/details/72550701#面向对象和面向过程的区别 http://blog.csdn.net/csd ...
Linux多线程的同步-----信号量和互斥锁
前面两篇给基本概念讲过了,大家有兴趣的可以去看一下: Linux多线程_神厨小福贵!的博客-CSDN博客进程和线程的区别有哪些呢?进程是资源分配的最小单位,线程是CPU调度的最小单位进程有自己的独立地 ...
java同步锁售票_Java基础学习笔记：多线程，线程池，同步锁（Lock，synchronized ）(Thread类,ExecutorService ，Future类)（卖火车票案例）...
学习多线程之前,我们先要了解几个关于多线程有关的概念. 进程:进程指正在运行的程序.确切的来说,当一个程序进入内存运行,即变成一个进程,进程是处于运行过程中的程序,并且具有一定独立功能. 线程:线程是 ...
python—多线程数据混乱问题解决之同步锁
一.同步问题产生的原因就是没有控制多个线程对同一资源的访问,对数据造成破坏,使得线程运行的结果不可预期.这种现象称为"线程不安全"". 同步:就是协同步调,按预定的先后 ...

Android多线程之同步锁的使用

Android多线程之同步锁的使用相关推荐

最新文章

热门文章