文档章节

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 NIO编程入门(一)

JAVA NIO编程入门(一) 一、前言 笔者之前接触的NIO编程比较少,所以对这一块的基础也比较弱,NIO作为java编程中一个重要的模块,不能很好的掌握它,感觉自己在java方面就掌握的不够,所以,...

木木匠
09/01
0
0
JDK源码阅读:ByteBuffer

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

木杉的博客
08/10
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

没有更多内容

加载失败,请刷新页面

加载更多

Java并发编程:volatile关键字解析

volatile这个关键字可能很多朋友都听说过,或许也都用过。在Java 5之前,它是一个备受争议的关键字,因为在程序中使用它往往会导致出人意料的结果。在Java 5之后,volatile关键字才得以重获生...

engeue
15分钟前
0
0
通过ajax访问远程天气预报服务

http://www.webxml.com.cn/zh_cn/index.aspx 更改wsdl文件 打开文件将15行,51行,101行去掉 然后把文件复制到c盘 然后在桌面上面就生成了文件 将文件打成jar包 package cn.it.ws.weather;...

江戸川
今天
1
0
聊聊storm的tickTuple

序 本文主要研究一下storm的tickTuple 实例 TickWordCountBolt public class TickWordCountBolt extends BaseBasicBolt { private static final Logger LOGGER = LoggerFactory.getLogg......

go4it
今天
1
0
自动装箱和自动拆箱

自动装箱和自动拆箱 Java 提供了 8 种基本数据类型,每种数据类型都有其对应的包装类型,包装类是面向对象的类,是一种高级的数据类型,可以进行一些比较复杂的操作,它们是引用类型而不再基...

tsmyk0715
今天
2
0
简易审计系统

1、有时候我们需要对线上用户的操作进行记录,可以进行追踪,出现问题追究责任,但是linux自带的history并不会实时的记录(仅仅在内存中,当用户正常退出(exit logout )时才会记录到history文件里...

芬野de博客
今天
3
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部