淺談多線程中的鎖的幾種用法總結(jié)(必看)
更新時(shí)間：2017年05月22日 10:43:23 投稿：jingxian
下面小編就為大家?guī)硪黄獪\談多線程中的鎖的幾種用法總結(jié)(必看)。小編覺得挺不錯(cuò)的，現(xiàn)在就分享給大家，也給大家做個(gè)參考。一起跟隨小編過來看看吧
一、ReentrantLock
package com.ietree.basicskill.mutilthread.lock;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
/**
* Created by Administrator on 2017/5/17.
*/
public class UseReentrantLock {
private Lock lock = new ReentrantLock();
public void method1(){
try {
lock.lock();
System.out.println("當(dāng)前線程:" + Thread.currentThread().getName() + "進(jìn)入method1..");
Thread.sleep(1000);
System.out.println("當(dāng)前線程:" + Thread.currentThread().getName() + "退出method1..");
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
lock.unlock();
}
}
public void method2(){
try {
lock.lock();
System.out.println("當(dāng)前線程:" + Thread.currentThread().getName() + "進(jìn)入method2..");
Thread.sleep(2000);
System.out.println("當(dāng)前線程:" + Thread.currentThread().getName() + "退出method2..");
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
lock.unlock();
}
}
public static void main(String[] args) {
final UseReentrantLock ur = new UseReentrantLock();
Thread t1 = new Thread(new Runnable() {
@Override
public void run() {
ur.method1();
ur.method2();
}
}, "t1");
t1.start();
try {
Thread.sleep(10);
} catch (InterruptedException e) {
e.printStackTrace();
}
//System.out.println(ur.lock.getQueueLength());
}
}
二、ReentrantReadWriteLock
package com.ietree.basicskill.mutilthread.lock;
import java.util.concurrent.locks.ReentrantReadWriteLock;
/**
* Created by Administrator on 2017/5/17.
*/
public class UseReentrantReadWriteLock {
private ReentrantReadWriteLock rwLock = new ReentrantReadWriteLock();
private ReentrantReadWriteLock.ReadLock readLock = rwLock.readLock();
private ReentrantReadWriteLock.WriteLock writeLock = rwLock.writeLock();
public void read(){
try {
readLock.lock();
System.out.println("當(dāng)前線程:" + Thread.currentThread().getName() + "進(jìn)入...");
Thread.sleep(3000);
System.out.println("當(dāng)前線程:" + Thread.currentThread().getName() + "退出...");
} catch (Exception e) {
e.printStackTrace();
} finally {
readLock.unlock();
}
}
public void write(){
try {
writeLock.lock();
System.out.println("當(dāng)前線程:" + Thread.currentThread().getName() + "進(jìn)入...");
Thread.sleep(3000);
System.out.println("當(dāng)前線程:" + Thread.currentThread().getName() + "退出...");
} catch (Exception e) {
e.printStackTrace();
} finally {
writeLock.unlock();
}
}
public static void main(String[] args) {
final UseReentrantReadWriteLock urrw = new UseReentrantReadWriteLock();
Thread t1 = new Thread(new Runnable() {
@Override
public void run() {
urrw.read();
}
}, "t1");
Thread t2 = new Thread(new Runnable() {
@Override
public void run() {
urrw.read();
}
}, "t2");
Thread t3 = new Thread(new Runnable() {
@Override
public void run() {
urrw.write();
}
}, "t3");
Thread t4 = new Thread(new Runnable() {
@Override
public void run() {
urrw.write();
}
}, "t4");
// t1.start();
// t2.start();
// t1.start(); // R
// t3.start(); // W
t3.start();
t4.start();
}
}
三、Condition
package com.ietree.basicskill.mutilthread.lock;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
/**
* Created by Administrator on 2017/5/17.
*/
public class UseCondition {
private Lock lock = new ReentrantLock();
private Condition condition = lock.newCondition();
public void method1(){
try {
lock.lock();
System.out.println("當(dāng)前線程：" + Thread.currentThread().getName() + "進(jìn)入等待狀態(tài)..");
Thread.sleep(3000);
System.out.println("當(dāng)前線程：" + Thread.currentThread().getName() + "釋放鎖..");
condition.await(); // Object wait
System.out.println("當(dāng)前線程：" + Thread.currentThread().getName() +"繼續(xù)執(zhí)行...");
} catch (Exception e) {
e.printStackTrace();
} finally {
lock.unlock();
}
}
public void method2(){
try {
lock.lock();
System.out.println("當(dāng)前線程：" + Thread.currentThread().getName() + "進(jìn)入..");
Thread.sleep(3000);
System.out.println("當(dāng)前線程：" + Thread.currentThread().getName() + "發(fā)出喚醒..");
condition.signal(); //Object notify
} catch (Exception e) {
e.printStackTrace();
} finally {
lock.unlock();
}
}
public static void main(String[] args) {
final UseCondition uc = new UseCondition();
Thread t1 = new Thread(new Runnable() {
@Override
public void run() {
uc.method1();
}
}, "t1");
Thread t2 = new Thread(new Runnable() {
@Override
public void run() {
uc.method2();
}
}, "t2");
t1.start();
t2.start();
}
}
四、ManyCondition
package com.ietree.basicskill.mutilthread.lock;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.ReentrantLock;
/**
* Created by Administrator on 2017/5/17.
*/
public class UseManyCondition {
private ReentrantLock lock = new ReentrantLock();
private Condition c1 = lock.newCondition();
private Condition c2 = lock.newCondition();
public void m1(){
try {
lock.lock();
System.out.println("當(dāng)前線程：" +Thread.currentThread().getName() + "進(jìn)入方法m1等待..");
c1.await();
System.out.println("當(dāng)前線程：" +Thread.currentThread().getName() + "方法m1繼續(xù)..");
} catch (Exception e) {
e.printStackTrace();
} finally {
lock.unlock();
}
}
public void m2(){
try {
lock.lock();
System.out.println("當(dāng)前線程：" +Thread.currentThread().getName() + "進(jìn)入方法m2等待..");
c1.await();
System.out.println("當(dāng)前線程：" +Thread.currentThread().getName() + "方法m2繼續(xù)..");
} catch (Exception e) {
e.printStackTrace();
} finally {
lock.unlock();
}
}
public void m3(){
try {
lock.lock();
System.out.println("當(dāng)前線程：" +Thread.currentThread().getName() + "進(jìn)入方法m3等待..");
c2.await();
System.out.println("當(dāng)前線程：" +Thread.currentThread().getName() + "方法m3繼續(xù)..");
} catch (Exception e) {
e.printStackTrace();
} finally {
lock.unlock();
}
}
public void m4(){
try {
lock.lock();
System.out.println("當(dāng)前線程：" +Thread.currentThread().getName() + "喚醒..");
c1.signalAll();
} catch (Exception e) {
e.printStackTrace();
} finally {
lock.unlock();
}
}
public void m5(){
try {
lock.lock();
System.out.println("當(dāng)前線程：" +Thread.currentThread().getName() + "喚醒..");
c2.signal();
} catch (Exception e) {
e.printStackTrace();
} finally {
lock.unlock();
}
}
public static void main(String[] args) {
final UseManyCondition umc = new UseManyCondition();
Thread t1 = new Thread(new Runnable() {
@Override
public void run() {
umc.m1();
}
},"t1");
Thread t2 = new Thread(new Runnable() {
@Override
public void run() {
umc.m2();
}
},"t2");
Thread t3 = new Thread(new Runnable() {
@Override
public void run() {
umc.m3();
}
},"t3");
Thread t4 = new Thread(new Runnable() {
@Override
public void run() {
umc.m4();
}
},"t4");
Thread t5 = new Thread(new Runnable() {
@Override
public void run() {
umc.m5();
}
},"t5");
t1.start(); // c1
t2.start(); // c1
t3.start(); // c2
try {
Thread.sleep(2000);
} catch (InterruptedException e) {
e.printStackTrace();
}
t4.start(); // c1
try {
Thread.sleep(2000);
} catch (InterruptedException e) {
e.printStackTrace();
}
t5.start(); // c2
}
}
以上這篇淺談多線程中的鎖的幾種用法總結(jié)(必看)就是小編分享給大家的全部內(nèi)容了，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。
您可能感興趣的文章:
相關(guān)文章
這篇文章主要為大家詳細(xì)介紹了java設(shè)計(jì)模式之抽像工廠的相關(guān)資料，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2017-09-09
這篇文章主要介紹了Java中的代理原理及代理使用示例,本文講解了Java Socket編程中加入代理的2種方法,需要的朋友可以參考下2015-03-03
Springboot實(shí)現(xiàn)視頻上傳及壓縮功能
這篇文章主要介紹了Springboot實(shí)現(xiàn)視頻上傳及壓縮功能,本文通過實(shí)例代碼給大家介紹的非常詳細(xì)，對大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下2023-03-03
這篇文章主要介紹了Java反射如何修改private final成員變量值,文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2019-07-07
這篇文章主要介紹了JSON序列化Redis讀取出錯(cuò)問題解決方案,文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-09-09
MapReduce是一種編程模型，用于大規(guī)模數(shù)據(jù)集的并行運(yùn)算。概念"Map(映射)"和"Reduce(歸約)"和他們的主要思想，都是從函數(shù)式編程語言里借來的，還有從矢量編程語言里借來的特性。他極大地方便了編程人員在不會(huì)分布式并行編程的情況下，將自己的程序運(yùn)行在分布式系統(tǒng)上。2014-08-08
這篇文章主要介紹了Java中Range函數(shù)的簡單介紹，Java中的range方法用于返回IntStream和LongStream在函數(shù)參數(shù)范圍內(nèi)的順序值2022-07-07
在本篇文章里我們給大家詳細(xì)講述了java對同一個(gè)文件進(jìn)行讀寫操作的方法和知識(shí)點(diǎn)，需要的朋友們可以參考學(xué)習(xí)下。2018-10-10
在Java開發(fā)中，經(jīng)常需要?jiǎng)?chuàng)建線程去執(zhí)行一些任務(wù)，實(shí)現(xiàn)起來也非常方便，此時(shí)，我們很自然會(huì)想到使用線程池來解決這個(gè)問題，文中給大家提到使用線程池的好處，對Java線程池空閑線程知識(shí)感興趣的朋友一起看看吧2021-06-06
這篇文章主要介紹了Spring IO Platform簡單介紹，具有一定借鑒價(jià)值,需要的朋友可以參考下2017-12-12