在例1中的ClassicSingleton.getInstance()方法由于下面的代碼而不是線程安全的:
- 1: if(instance == null) {
- 2: instance = new Singleton();
- 3: }
如果一個線程在第二行的賦值語句發生之前切換,那么成員變量instance仍然是null,然后另一個線程可能接下來進入到if塊中。在這種情況下,兩個不同的單例類實例就被創建。不幸的是這種假定很少發生,這樣這種假定也很難在測試期間出現(譯注:在這可能是作者對很少出現這種情況而導致無法測試從而使人們放松警惕而感到嘆惜)。為了演示這個線程輪換,我得重新實現例1中的那個類。例4就是修訂后的單例類:
例4.人為安排的方式
- import org.apache.log4j.Logger;
- public class Singleton {
- private static Singleton singleton = null;
- private static Logger logger = Logger.getRootLogger();
- private static boolean firstThread = true;
- protected Singleton() {
- // Exists only to defeat instantiation.
- }
- public static Singleton getInstance() {
- if(singleton == null) {
- simulateRandomActivity();
- singleton = new Singleton();
- }
- logger.info("created singleton: " + singleton);
- return singleton;
- }
- private static void simulateRandomActivity() {
- try {
- if(firstThread) {
- firstThread = false;
- logger.info("sleeping...");
- // This nap should give the second thread enough time
- // to get by the first thread.
- Thread.currentThread().sleep(50);
- }
- }
- catch(InterruptedException ex) {
- logger.warn("Sleep interrupted");
- }
- }
- }
除了在這個清單中的單例類強制使用了一個多線程錯誤處理,例4類似于例1中的單例類。在getInstance()方法第一次被調用時,調用這個方法的線程會休眠50毫秒以便另外的線程也有時間調用getInstance()并創建一個新的單例類實例。當休眠的線程覺醒時,它也會創建一個新的單例類實例,這樣我們就有兩個單例類實例。盡管例4是人為如此的,但它卻模擬了第一個線程調用了getInstance()并在沒有完成時被切換的真實情形。
例5測試了例4的單例類:
例5.失敗的測試
- import org.apache.log4j.Logger;
- import junit.framework.Assert;
- import junit.framework.TestCase;
- public class SingletonTest extends TestCase {
- private static Logger logger = Logger.getRootLogger();
- private static Singleton singleton = null;
- public SingletonTest(String name) {
- super(name);
- }
- public void setUp() {
- singleton = null;
- }
- public void testUnique() throws InterruptedException {
- // Both threads call Singleton.getInstance().
- Thread threadOne = new Thread(new SingletonTestRunnable()),
- threadTwo = new Thread(new SingletonTestRunnable());
- threadOne.start();
- threadTwo.start();
- threadOne.join();
- threadTwo.join();
- }
- private static class SingletonTestRunnable implements Runnable {
- public void run() {
- // Get a reference to the singleton.
- Singleton s = Singleton.getInstance();
- // Protect singleton member variable from
- // multithreaded access.
- synchronized(SingletonTest.class) {
- if(singleton == null) // If local reference is null...
- singleton = s; // ...set it to the singleton
- }
- // Local reference must be equal to the one and
- // only instance of Singleton; otherwise, we have two
- // Singleton instances.
- Assert.assertEquals(true, s == singleton);
- }
- }
- }
例5的測試案例創建兩個線程,然后各自啟動,等待完成。這個案例保持了一個對單例類的靜態引用,每個線程都會調用Singleton.getInstance()。如果這個靜態成員變量沒有被設置,那么第一個線程就會將它設為通過調用getInstance()而得到的引用,然后這個靜態變量會與一個局部變量比較是否相等。
在這個測試案例運行時會發生一系列的事情:第一個線程調用getInstance(),進入if塊,然后休眠;接著,第二個線程也調用getInstance()并且創建了一個單例類的實例。第二個線程會設置這個靜態成員變量為它所創建的引用。第二個線程檢查這個靜態成員變量與一個局部備份的相等性。然后測試通過。當第一個線程覺醒時,它也會創建一個單例類的實例,并且它不會設置那個靜態成員變量(因為第二個線程已經設置過了),所以那個靜態變量與那個局部變量脫離同步,相等性測試即告失敗。例6列出了例5的輸出:
例6.例5的輸出
- Buildfile: build.xml
- init:
- [echo] Build 20030414 (14-04-2003 03:06)
- compile:
- run-test-text:
- INFO Thread-1: sleeping...
- INFO Thread-2: created singleton: Singleton@7e5cbd
- INFO Thread-1: created singleton: Singleton@704ebb
- junit.framework.AssertionFailedError: expected: but was:
- at junit.framework.Assert.fail(Assert.java:47)
- at junit.framework.Assert.failNotEquals(Assert.java:282)
- at junit.framework.Assert.assertEquals(Assert.java:64)
- at junit.framework.Assert.assertEquals(Assert.java:149)
- at junit.framework.Assert.assertEquals(Assert.java:155)
- at SingletonTest$SingletonTestRunnable.run(Unknown Source)
- at java.lang.Thread.run(Thread.java:554)
- [java] .
- [java] Time: 0.577
- [java] OK (1 test)
到現在為止我們已經知道例4不是線程安全的,那就讓我們看看如何修正它。
同步
要使例4的單例類為線程安全的很容易----只要像下面一個同步化getInstance()方法:
- public synchronized static Singleton getInstance() {
- if(singleton == null) {
- simulateRandomActivity();
- singleton = new Singleton();
- }
- logger.info("created singleton: " + singleton);
- return singleton;
- }
在同步化getInstance()方法后,我們就可以得到例5的測試案例返回的下面的結果:
- Buildfile: build.xml
- init:
- [echo] Build 20030414 (14-04-2003 03:15)
- compile:
- [javac] Compiling 2 source files
- run-test-text:
- INFO Thread-1: sleeping...
- INFO Thread-1: created singleton: Singleton@ef577d
- INFO Thread-2: created singleton: Singleton@ef577d
- [java] .
- [java] Time: 0.513
- [java] OK (1 test)
這此,這個測試案例工作正常,并且多線程的煩惱也被解決;然而,機敏的讀者可能會認識到getInstance()方法只需要在第一次被調用時同步。因為同步的性能開銷很昂貴(同步方法比非同步方法能降低到100次左右),或許我們可以引入一種性能改進方法,它只同步單例類的getInstance()方法中的賦值語句。