聊聊BitCaskLock
时间:2022-07-24
本文章向大家介绍聊聊BitCaskLock,主要内容包括其使用实例、应用技巧、基本知识点总结和需要注意事项,具有一定的参考价值,需要的朋友可以参考一下。
序
本文主要研究一下BitCaskLock
BitCaskLock
bitcask-java/src/main/java/com/trifork/bitcask/BitCaskLock.java
public class BitCaskLock {
public static enum Stale {
OK, NOT_STALE
}
public static enum Type {
WRITE, MERGE;
private String type_name() {
if (this == MERGE) return "merge";
if (this == WRITE) return "write";
throw new RuntimeException();
}
}
private RandomAccessFile file;
private boolean is_write_lock;
private File filename;
private BitCaskLock(RandomAccessFile file, File filename, boolean isWriteLock) {
this.file = file;
this.filename = filename;
this.is_write_lock = isWriteLock;
}
public static BitCaskLock acquire(Type type, File dirname) throws IOException {
File lock_filename = lock_filename(type, dirname);
foo: do {
try {
BitCaskLock lock = lock_acquire(lock_filename, true);
String lock_contents = Integer.toString(OS.getpid()) + " n";
lock.write_data(ByteString.copyFromUtf8(lock_contents));
return lock;
} catch (FileAlreadyExistsException e) {
delete_stale_lock(lock_filename);
continue foo;
}
} while (false);
return null;
}
public void release() throws IOException {
if (file != null) {
if (is_write_lock) {
file.close();
filename.delete();
}
}
file = null;
}
//......
}
- BitCaskLock的acquire方法,先通过lock_acquire获取BitCaskLock,如果出现FileAlreadyExistsException则执行delete_stale_lock;其release方法针对is_write_lock执行file.close()及filename.delete()
lock_acquire
bitcask-java/src/main/java/com/trifork/bitcask/BitCaskLock.java
private static BitCaskLock lock_acquire(File lockFilename, boolean is_write_lock)
throws IOException {
if (is_write_lock) {
if (lockFilename.createNewFile() == false) {
// file already exists, so we fail!
throw new FileAlreadyExistsException(lockFilename);
}
}
RandomAccessFile f = new RandomAccessFile(lockFilename,
is_write_lock ? "rws" : "r");
return new BitCaskLock(f, lockFilename, is_write_lock);
}
- lock_acquire方法针对is_write_lock,执行lockFilename.createNewFile(),若为false则抛出FileAlreadyExistsException
delete_stale_lock
bitcask-java/src/main/java/com/trifork/bitcask/BitCaskLock.java
public static Stale delete_stale_lock(Type type, File dirname) throws IOException {
return delete_stale_lock(lock_filename(type, dirname));
}
private static Stale delete_stale_lock(File lockFilename) throws IOException {
BitCaskLock l = null;
try {
l = lock_acquire(lockFilename, false);
} catch (FileNotFoundException e) {
return Stale.OK;
} catch (IOException e) {
return Stale.NOT_STALE;
}
try {
int pid = l.read_lock_data_pid();
if (OS.pid_exists(pid)) {
return Stale.NOT_STALE;
} else {
lockFilename.delete();
return Stale.OK;
}
} catch (IOException e) {
return Stale.NOT_STALE;
} finally {
l.release();
}
}
- delete_stale_lock方法先执行lock_acquire,若出现FileNotFoundException,则返回Stale.OK,若出现IOException则返回Stale.NOT_STALE;否则通过l.read_lock_data_pid()获取pid,若OS.pid_exists(pid)则返回Stale.NOT_STALE,否则执行lockFilename.delete(),返回Stale.OK;最后执行l.release()
小结
BitCaskLock的acquire方法,先通过lock_acquire获取BitCaskLock,如果出现FileAlreadyExistsException则执行delete_stale_lock;其release方法针对is_write_lock执行file.close()及filename.delete()
doc
- [Android] Toast问题深度剖析(二)
- [Android] Toast问题深度剖析(一)
- android离线缓存技术
- 浅谈ViewModel
- Android深入理解JNI(二)类型转换、方法签名和JNIEnv
- 探讨通过Feign配合Hystrix进行调用时异常的处理
- 小窗播放视频的原理和实现(上)
- 一种Android App在Native层动态加载so库的方案
- java的双缓冲技术
- application之OnLowMemory()和 OnTrimMemory(level)讲解
- React Native组件(一)组件的生命周期
- Spring Cloud构建微服务架构:服务消费(基础)【Dalston版】
- Android解析ClassLoader(一)Java中的ClassLoader
- Android学习笔记(一)之仿正点闹钟时间齿轮滑动的效果
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法
- 爬取上市公司数据、分析数据,并用可视化现实全国各地区公司数量
- 今天刚上手爬虫,当然要从最简单的开始啦,验证一下所学的知识
- Python数据可视化入门:使用Matplotlib绘图
- 有了音乐下载器,怎么能没有音乐播放器呢,打造自己的音乐播放器
- 七夕节到了,单身狗程序员要对自己好点,用代码送自己点安慰
- 面向对象视角下的前端工程体系
- 使用 Python破解大众点评字体加密(SVG反爬虫)
- Python爬虫练习:爬取高清4K桌面壁纸
- 爬取B站18000条《黑神话:悟空》实机演示弹幕,做成词云
- Python爬虫实战:自动化登录网站,爬取商品数据
- 符合自己的工作难找?取招聘网站数据,让你找到心仪的工作
- 虽然现在有可以去码的软件了,可视频是如何自动跟踪打码的?
- Python爬取NBA虎扑球员数据
- 发现一个好看的手机壁纸网站,撸代码的手已经饥渴难耐了
- 手把手用python教你拿即时的卫星影像装饰你的桌面