本篇內(nèi)容介紹了“java中BitCaskLock的使用方法”的有關知識，在實際案例的操作過程中，不少人都會遇到這樣的困境，接下來就讓小編帶領大家學習一下如何處理這些情況吧！希望大家仔細閱讀，能夠學有所成！

高邑ssl適用于網(wǎng)站、小程序/APP、API接口等需要進行數(shù)據(jù)傳輸應用場景，ssl證書未來市場廣闊！成為成都創(chuàng)新互聯(lián)的ssl證書銷售渠道，可以享受市場價格4-6折優(yōu)惠！如果有意向歡迎電話聯(lián)系或者加微信：18982081108（備注：SSL證書合作）期待與您的合作！

序

本文主要研究一下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，如果出現(xiàn)FileAlreadyExistsException則執(zhí)行delete_stale_lock；其release方法針對is_write_lock執(zhí)行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，執(zhí)行l(wèi)ockFilename.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方法先執(zhí)行l(wèi)ock_acquire，若出現(xiàn)FileNotFoundException，則返回Stale.OK，若出現(xiàn)IOException則返回Stale.NOT_STALE；否則通過l.read_lock_data_pid()獲取pid，若OS.pid_exists(pid)則返回Stale.NOT_STALE，否則執(zhí)行l(wèi)ockFilename.delete()，返回Stale.OK；最后執(zhí)行l(wèi).release()

小結

BitCaskLock的acquire方法，先通過lock_acquire獲取BitCaskLock，如果出現(xiàn)FileAlreadyExistsException則執(zhí)行delete_stale_lock；其release方法針對is_write_lock執(zhí)行file.close()及filename.delete()

“java中BitCaskLock的使用方法”的內(nèi)容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業(yè)相關的知識可以關注創(chuàng)新互聯(lián)網(wǎng)站，小編將為大家輸出更多高質量的實用文章！

網(wǎng)站欄目：java中BitCaskLock的使用方法
分享鏈接：http://www.chinadenli.net/article4/gpepoe.html

成都網(wǎng)站建設公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站收錄、網(wǎng)頁設計公司、小程序開發(fā)、外貿(mào)建站、品牌網(wǎng)站制作、域名注冊

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉載內(nèi)容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉載，或轉載時需注明來源： 創(chuàng)新互聯(lián)