文档章节

java模拟实现简单的读写锁

指尖残雪
 指尖残雪
发布于 2016/05/22 23:56
字数 292
阅读 4
收藏 0

当一个文件进行读的时候,其他线程也可以进行读,但是不能写入,当一个文件进行写的时候,其他线程不能读和写。

我将使用一个数组形式的数据模拟读写的简单锁操作进行控制。

package org.dyb.readwrite;

public class DataHandler {
    private char[] buffer = "AAAAAAAAAAA".toCharArray();
    
    private ReadWriteLock rwl = new ReadWriteLock();
    
    public char[] read(String name) {
        System.out.println(name + "waiting for read ...");
        rwl.readLock();
        try {
            char[] data = doRead();
            System.out.println(name + "reads data " + new String(data));
            return data;
        } finally{
            rwl.readUnlock();
        }
    }
    
    public void write(String name,char[] data){
        System.out.println(name + "waiting for write ...");
        rwl.writeLock();
        try {
            System.out.println(name + "reads data " + new String(data));
            doWrite(data);
        }finally{
            rwl.writeUnlock();
        }
        
    }
    
    
    private char[] doRead(){
        char[] ret = new char[buffer.length];
        for(int i=0;i<buffer.length;i++){
            ret[i] = buffer[i];
            sleep(3);
        }
        return ret;
    }
    private void doWrite(char[] data){
        buffer = new char[data.length];
        for(int i=0;i<data.length;i++){
            buffer[i] = data[i];
            sleep(10);
        }
    } 

    private void sleep(int ms) {
        try {
            Thread.sleep(ms);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
    
    
}
在读写的操作上进行加锁。

package org.dyb.readwrite;

public class ReadWriteLock {
    
    private int readingThreads = 0;
    private int writingThreads = 0;
    private int waitingThreads = 0;
    
    private boolean preferWrite = true;
    
    public synchronized void readLock(){
        while(writingThreads>0||(preferWrite&&waitingThreads>0)){
            try {
                this.wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        readingThreads++;
    }
    
    public synchronized void readUnlock(){
        readingThreads--;
        preferWrite = true;
        notifyAll();
    }
    
    public synchronized void writeLock(){
        waitingThreads++;
        while(readingThreads>0||writingThreads>0){
            try {
                this.wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }finally{
                waitingThreads--;
            }
        }
        writingThreads++;
    }
    
    public synchronized void writeUnlock(){
        writingThreads--;
        preferWrite = false;
        notifyAll();
    }
    
}



本文转载自:http://blog.csdn.net/bq1073100909/article/details/48414087

共有 人打赏支持
指尖残雪
粉丝 7
博文 73
码字总数 0
作品 0
上海
后端工程师
多线程编程读书笔记之线程中断的本质

Java试图提供过抢占式限制中断,但问题多多,例如已被废弃的Thread.stop、Thread.suspend和 Thread.resume等。另一方面,出于Java应用代码的健壮性的考虑,降低了编程门槛,减少不清楚底层机...

刘学炜
2012/07/03
0
0
JAVA线程13 - 新特性:Lock和条件变量

一、Lock 1. 概述 Lock是JDK 1.5以后将同步和锁封装成了对象。Lock是对之前synchronized的替代。 Lock接口的实现类:互斥锁ReentrantLock 。 2. synchronized与Lock区别 synchronized对于锁的...

小米米儿小
2014/03/05
0
0
Java线程(八):锁对象Lock-同步问题更完美的处理方式

原文: http://blog.csdn.net/ghsau/article/details/7461369 Lock是java.util.concurrent.locks包下的接口,Lock 实现提供了比使用synchronized 方法和语句可获得的更广泛的锁定操作,它能以...

干死it
2014/01/20
0
0
JDK源码阅读:ByteBuffer

原文出处:木杉的博客 Buffer是Java NIO中对于缓冲区的封装。在Java BIO中,所有的读写API,都是直接使用byte数组作为缓冲区的,简单直接。但是在Java NIO中,缓冲区这一概念变得复杂,可能是...

木杉的博客
08/10
0
0
Java锁有哪些种类,以及区别

一、公平锁/非公平锁 公平锁是指多个线程按照申请锁的顺序来获取锁。 非公平锁是指多个线程获取锁的顺序并不是按照申请锁的顺序,有可能后申请的线程比先申请的线程优先获取锁。有可能,会造...

晨猫
03/23
0
0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

困扰当前数据中心管理的三大难题

导读 当企业发展到一定程度,或者之前的机房不能满足现在的数据中心使用时,企业会对数据中心进行迁移。那么在数据中心进行迁移的时候会遇到哪些风险呢?针对这些风险我们应该做出怎样的措施来...

问题终结者
5分钟前
0
0
设计模式:工厂方法模式(工厂模式)

工厂方法模式才是真正的工厂模式,前面讲到的静态工厂模式实际上不能说是一种真正意义上的设计模式,只是一种变成习惯。 工厂方法的类图: 这里面涉及到四个种类: 1、抽象产品: Product 2、...

京一
21分钟前
0
0
区块链和数据库,技术到底有何区别?

关于数据库和区块链,总会有很多的困惑。区块链其实是一种数据库,因为他是数字账本,并且在区块的数据结构上存储信息。数据库中存储信息的结构被称为表格。但是,区块链是数据库,数据库可不...

HiBlock
29分钟前
0
0
react native 开发碰到的问题

react-navigation v2 问题 问题: static navigationOptions = ({navigation, navigationOptions}) => ({ headerTitle: ( <Text style={{color:"#fff"}}>我的</Text> ), headerRight: ( <View......

罗培海
36分钟前
0
0
Mac Docker安装流程

久仰Docker大名已久,于是今天趁着有空,尝试了一下Docker 先是从docker的官网上下载下来mac版本的docker安装包,安装很简易,就直接拖图标就好了。 https://www.docker.com/products/docker...

writeademo
44分钟前
0
0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部