python filelock 文件锁_详解进程文件锁FileLock

python filelock 文件锁_详解进程文件锁FileLockimportjava.io.FileNotFoundException;importjava.io.IOException;importjava.io.RandomAccessFile;importjava.nio.ByteBuffer;importjava.nio.channels.FileChannel;importjava.nio.channels.FileLock;import…

大家好,又见面了,我是你们的朋友全栈君。

import java.io.FileNotFoundException;

import java.io.IOException;

import java.io.RandomAccessFile;

import java.nio.ByteBuffer;

import java.nio.channels.FileChannel;

import java.nio.channels.FileLock;

import java.util.Date;

/**

* FileLocke是文件锁,进程锁,控制不同程序(JVM)对同一文件的并发访问

* FileLock是java 1.4 版本后出现的一个类,它可以通过对一个可写文件(w)加锁,

* 保证同时只有一个进程可以拿到文件的锁,这个进程从而可以对文件做访问;

* 而其它拿不到锁的进程要么选择被挂起等待,要么选择去做一些其它的事情,

* 这样的机制保证了众进程可以顺序访问该文件。

* 也可以看出,能够利用文件锁的这种性质,在一些场景下,虽然我们不需要操作某个文件,

* 但也可以通过 FileLock 来进行并发控制,保证进程的顺序执行,避免数据错误。

* —用于进程间并发

* Locks are associated with files, not channels. Use locks to coordinate

* with external processes, not between threads in the same JVM.

* —概念

* 共享锁:共享读操作,但只能一个写

* 排它锁:只有一个读或一个写

* API中说:文件锁是独占或者共享的,共享锁防止其他正在运行的程序获得重复的独占锁,但是允许他们获得

* 重复的共享锁,独占锁防止其他程序获得任何类型的锁。一旦锁释放,它就对其他程序可能要获得的锁没有了后续影响.

* —FileLock FileChannel.lock(long position, long size, boolean shared),文件锁

* shared的含义:是否使用共享锁,一些不支持共享锁的操作系统,将自动将共享锁改成排它锁.

* 可以通过调用isShared()方法来检测获得的是什么类型的锁

* —lock()和tryLock()的区别

* lock()阻塞的方法,锁定范围可以随着文件的增大而增加

* tryLock()非阻塞,当未获得锁时,返回null.

* —FileLock的生命周期

* 在调用FileLock.release(),或者Channel.close(),或者JVM关闭

* —FileLock是线程安全的

* —boolean java.nio.channels.FileLock.overlaps(long position, long size)

* true表示当前锁在区域内,false表示当前锁的区域与参数区域不重叠

*     注意事项:

1.同一进程内,在文件锁没有被释放之前,不可以再次获取。

即在release()方法调用前,只能lock()或者tryLock()一次。

2.文件锁的效果是与操作系统相关的。一些系统中文件锁是强制性的(mandatory),

就当Java的某进程获得文件锁后,操作系统将保证其它进程无法对文件做操作了。

而另一些操作系统的文件锁是询问式的(advisory),意思是说要想拥有进程互斥的效果,

其它的进程也必须也按照API所规定的那样来申请或者检测文件锁,不然,将起不到进程互斥的功能。

所以,文档里建议将所有系统都当做是询问式系统来处理,这样程序更加安全也更容易移植。

*如何避免死锁

在读写关键数据时加锁,操作完成后解锁;

一次性申请所有需要的资源,并且在申请不成功的情况下放弃已申请到的资源;

* @author shijin

*

*/

public class FileLockTest {

/**

* 如代码所示,需要进行互斥的进程只要将自己的代码替换掉//互斥操作即可,

* 每个进程在运行实际逻辑功能代码之前,会尝试获取锁文件锁,

* 得到文件锁的进程可以继续执行后续的代码,而没有获得锁文件的进程将被操作系统挂起(suspend),

* 等到其它进程将文件锁释放后再重新开始尝试获取文件锁。

* 这样子,进程就可以通过FileLock来实现间的互斥运行。

* @param args

*/

public static void main(String[] args){

FileChannel channel = null;

FileLock lock = null;

try {

//            对于一个只读文件通过任意方式加锁时会报NonWritableChannelException异常

//            同样对写通道通过有参lock()方式加锁时也会报NonReadableChannelException异常

//            无参lock()默认为独占锁,不会报NonReadableChannelException异常,因为独占就是为了写

//            所谓的共享也只能读共享,写是独占的,共享锁控制的代码只能是读操作

//            channel = new FileOutputStream(“logfile.txt”,true).getChannel();

RandomAccessFile raf = new RandomAccessFile(“logfile.txt”,”rw”);

raf.seek(raf.length());//raf在文件末尾追加内容的处理

channel = raf.getChannel();

//            获得锁方法一lock,阻塞的方法,当文件锁不可用时,当前进程会被挂起

//            lock = channel.lock(0L, Long.MAX_VALUE, true);//共享锁,有写操作会报异常

lock = channel.lock();//独占锁

//            获得锁方法二trylock,非阻塞的方法,当文件锁不可用时,tryLock()会得到null值

//            do {

//                lock = channel.tryLock();

//            } while(null == lock);

//            互斥操作

ByteBuffer sendBuffer=ByteBuffer.wrap((new Date()+” 写入\n”).getBytes());

channel.write(sendBuffer);

Thread.sleep(5000);

} catch (FileNotFoundException e) {

e.printStackTrace();

} catch (IOException e) {

e.printStackTrace();

} catch (InterruptedException e) {

e.printStackTrace();

} finally {

if(lock != null) {

try {

lock.release();

lock = null;

} catch (IOException e) {

e.printStackTrace();

}

}

if(channel != null) {

try {

channel.close();

channel = null;

} catch (IOException e) {

e.printStackTrace();

}

}

}

}

}

/**

*     间隔一秒钟两次运行本程序,程序会在文件锁的控制下对logfile.txt进行互斥操作

logfile.txt内容:

Thu Aug 16 15:39:02 CST 2012 写入

Thu Aug 16 15:39:07 CST 2012 写入

当采用第二种方法时,若还未获得文件锁就对文件进行操作,则会报以下异常:

Exception in thread “main” java.io.IOException: 另一个程序已锁定文件的一部分,进程无法访问。

at sun.nio.ch.FileDispatcher.write0(Native Method)

at sun.nio.ch.FileDispatcher.write(Unknown Source)

at sun.nio.ch.IOUtil.writeFromNativeBuffer(Unknown Source)

at sun.nio.ch.IOUtil.write(Unknown Source)

at sun.nio.ch.FileChannelImpl.write(Unknown Source)

at FileLockTest.main(FileLockTest.java:19)

*/

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/153491.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • OpenGL中glPushMatrix和glPopMatrix的原理「建议收藏」

    转自:http://www.bubuko.com/infodetail-435954.htmlglPushMatrix、glPopMatrix操作事实上就相当于栈里的入栈和出栈。  很多人不明确的可能是入的是什么,出的又是什么。比如你当前的坐标系原点在你电脑屏幕的左上方。如今你调用glPushMatrix,然后再调用一堆平移、旋转代码等等,然后再绘图。那些平移和旋转都是基于左上角为

  • 2021 pycharm专业版永久激活码破解方法

    2021 pycharm专业版永久激活码破解方法,https://javaforall.cn/100143.html。详细ieda激活码不妨到全栈程序员必看教程网一起来了解一下吧!

  • MyBatis-延迟加载与MyBatis缓存(面试题)

    MyBatis-延迟加载与MyBatis缓存(面试题)MyBatis-延迟加载与MyBatis缓存-概念性MyBatis-延迟加载与MyBatis缓存MyBatis-延迟加载与MyBatis缓存-概念性延迟加载(面试题)1、什么是延迟加载(按需加载)2、延迟加载MyBatis缓存(面试题)1、Cache缓存2、MyBatis缓存分析3、一级缓存4、二级缓存原理开启二级缓存5、禁用二级缓存6、刷新二级缓存延迟加载(面试题)1、什么是延迟加载(按需…

  • .htaccess文件RewriteRule语法规则

    .htaccess文件RewriteRule语法规则.htaccess文件是运行ApacheWebServer的Web服务器的配置文件,对配置和重定向ApacheWebServer文件系统很有用。请记住.htaccess文件将采用隐藏格式。没有人可以通过URL直接看到它。.htaccess文件有很多用途。在这里,我将讨论.htaccess文件RewriteRule语法规则。RewriteRule语法规则#——位于行首时表示注释。[F]——Forbidden(禁止):命令服务器返回403Forb…

  • Python定义计算矩阵转置的函数

    Python定义计算矩阵转置的函数定义计算矩阵转置的函数1)使用循环进行转置matrix=[[1,2,3,4],[5,6,7,8],[9,10,11,12]]#打印矩阵defprintMatrix(m):foreleinm:foreinele:print(‘%3d’%e,end=”)print(”)…

  • clone一个react项目怎么运行[通俗易懂]

    首先当你从git上面clone一个项目的时候怎么让项目跑起来,首先看项目目录结构,找到README.md上面有项目运行的步骤,如果没有可以看package.json文件,找到scripts上面有dev所以跑起来项目就使用npmrundev有start就使用npmstart但是要先安装项目依赖使用npminstall依赖下载完成就可以使用npmrundev/npm…

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号