跳到主要內容

Guava - File Changed Cache

Problem

讀取某個檔案建立model,可能因為成本昂貴而建立Cache;此外,程式可能會因為檔案有修改而重新建立Cache。本篇教學,將告訴你如何透過Guava達到這個需求。

How to?

Guava本身有提供ExpiringMemoizingSupplier讓你以時間為條件,去重讀cache;ExpiredFileMemorizeSupplier使用Proxy的概念,去控管何時該真的去讀實際資料。我參考這個做法,建立了ExpiredFileMemorizeSupplier物件,會根據檔案是否修改,去決定是否讀真實資料:

package org.tonylin.practice.guava.cache;
 
import java.io.File;
 
import com.google.common.base.Supplier;
 
public class ExpiredFileMemorizeSupplier<T> implements Supplier<T> {
 
	private File mFile;
	private Supplier<T> mDelegate;
	private long mLastModified = 0;
	private transient volatile T value;
 
	public ExpiredFileMemorizeSupplier(IFileDataSupplier<T> delegate){
		mFile = delegate.getFile();
		mDelegate = delegate;
	}
 
	public ExpiredFileMemorizeSupplier(Supplier<T> delegate, File file){
		mFile = file;
		mDelegate = delegate;
	}
 
	@Override
	public T get() {
		long lastModified = mFile.lastModified(); 
		synchronized (this) {
			if( lastModified != mLastModified ) {
				mLastModified = lastModified;
				value = mDelegate.get(); 
			}
			return value;	
		}
	}
}

通常提供資料的物件,本身應為對應檔案的Information Export;因此我另外定義IFileDataSupplier介面去做這事情:

package org.tonylin.practice.guava.cache;
 
import java.io.File;
 
import com.google.common.base.Supplier;
 
public interface IFileDataSupplier<T> extends Supplier<T> {
	File getFile();
}

以下為我的測試案例,去驗證資料是從cache來還是實際讀: (這延續之前的測試修改的,並非量身打造,莫見怪)

package org.tonylin.practice.guava.cache;
 
import java.io.File;
import java.io.IOException;
import java.net.MalformedURLException;
import java.nio.charset.Charset;
import java.util.concurrent.TimeUnit;
 
import org.junit.After;
import org.junit.Assert;
import org.junit.Before;
import org.junit.Test;
 
import com.google.common.base.Supplier;
import com.google.common.base.Suppliers;
import com.google.common.io.Files;
import com.google.common.io.Resources;
 
 
public class TestSuppliers {
 
	private int count = 0;
 
	private File testFile = new File("TestSuppliersTestFile.txt");
 
	@Before
	public void setup() throws Exception {
		Files.write("test".getBytes(), testFile);
	}
 
	@After
	public void teardown(){
		testFile.delete();
	}
 
	@Test
	public void testExpiredFileMemorizeSupplier_IFileDataSupplier() throws Exception {
		IFileDataSupplier<String> fileDataSupplier = new IFileDataSupplier<String>() {
			private File testFile = new File("TestSuppliersTestFile.txt");
 
			@Override
			public String get() {
				try {
					count++;
					return Resources.toString(testFile.toURI().toURL(), Charset.forName("utf-8"));
				} catch (Exception e) {
					throw new RuntimeException(e);
				}
			}
 
			@Override
			public File getFile() {
				return testFile;
			}
		};
 
		ExpiredFileMemorizeSupplier<String> s = new ExpiredFileMemorizeSupplier<>(fileDataSupplier);
 
		Assert.assertEquals( 0, count);
		Assert.assertEquals("test", s.get());
		Assert.assertEquals( 1, count);
		Assert.assertEquals("test", s.get());
		Assert.assertEquals( 1, count);
 
		Files.write("test2".getBytes(), testFile);
		Assert.assertEquals("test2", s.get());
		Assert.assertEquals( 2, count);
	}
 
	@Test
	public void testExpiredFileMemorizeSupplier() throws Exception{
		ExpiredFileMemorizeSupplier<String> s = new ExpiredFileMemorizeSupplier<>(this::getMemoize, testFile);
 
		Assert.assertEquals( 0, count);
		Assert.assertEquals("testMemoize", s.get());
		Assert.assertEquals( 1, count);
		Assert.assertEquals("testMemoize", s.get());
		Assert.assertEquals( 1, count);
 
		Files.write("test".getBytes(), testFile);
		Assert.assertEquals("testMemoize", s.get());
		Assert.assertEquals( 2, count);
	}
 
	public String getMemoize(){
		count++;
		return "testMemoize";
	}
}

也許應該設計成Event-based的Eviction?

留言

這個網誌中的熱門文章

PostgreSQL - Unattended installation on windows

Introduction 要將別人軟體包裝到自己軟體中,不可或缺的東西就是Unattended installation。以Unattended installation來說,我們可以選擇透過Installer的silent mode安裝,也可以透過把目標軟體做成portable的版本。本篇文章分享這兩種方法,教導大家如何將PostgreSQL透過Unattended installation方式安裝到目標系統成為service。 Note. 本篇以PostgreSQL 10.7為例。 Install with installer Tips 安裝程式或反安裝程式的參數,除了可以直接上官網搜尋Installation User Guide以外,也可以直接使用help參數查詢: postgresql- 10.7 - 2 -windows-x64.exe --help Windows安裝程式主要有EnterpriseDB與BigSQL兩種。BigSQL版本安裝元件是透過網路下載且支援參數不如EnterpriseDB版本多,以我們需求來說,我們傾向於使用EnterpriseDB版本。接下來分享給大家安裝與反安裝方法。 Installation @ echo off set INSTALL_DIR =C:\postgres10 set INSTALLER =postgresql- 10.7 - 2 -windows-x64.exe   rem options for installation set SSMDB_SERVICE =postgresql- 10 set MODE =--unattendedmodeui none --mode unattended   set DB_PASSWD =--superpassword postgres set DB_PORT =--serverport 5432   set SERVICE_NAME =--servicename % SSMDB_SERVICE %   set PREFIX =--prefix "%INSTALL_DIR%" set DATA_DIR =--datadir "%INSTALL_DIR%\data"   set OPTIONS =

How to install RIDE on Windows?

Introduction 多年沒在Windows上開發RobotFramework,趁著這次整理一下RIDE安裝方法。 目前RIDE最新版本與Python對應版本如下: (3.6 < python <= 3.11) Install current released version (2.0.8.1) with: pip install -U robotframework-ride 安裝Python 直接到Python官網找尋最新的3.11版本,我使用3.11.9: link 。安裝就是一直下一步而已。 安裝wxPython 每次安裝RIDE最困難的都是wxPython。看了一下 官網 描述,我就姑且相信一下: 接著進入下 載頁面 就有安裝教學。基本上就是到Python目錄下的Scripts直接執行以下command: pip install -U wxPython 安裝RIDE 接著就如RIDE官網所說,執行以下command: pip install -U robotframework-ride 啟動RIDE 直接在相同目錄下執行ride就可以啟動了,你也可以直接在桌面建ride連結,加快下次啟動時間。 沒想到這次這麼順利就安裝完成了。因為我是使用java去啟動robot framework,就不特別講要怎麼使用pip安裝robot framework了。

Hello World!

即將要搬家,因此舊網頁內容將慢慢轉移至Blogger。 如果要存取舊網頁,可以使用以下連結: https://wiki.tonylin.idv.tw/dokuwiki/doku.php