這段代碼中的錯誤在哪裏？

我創建了一個用作緩存提供者的類。它使用一個Map，時間戳映射條目，它產生一個Thread，每隔一段時間執行一次清理。該類用於Web應用程序。這個Web應用程序有一個問題，POST需要30秒。我將問題追溯到這個緩存類，消除了它解決了問題。這段代碼中的錯誤在哪裏？

我已盡全力在本課中找到錯誤，但我不能。請幫我在這裏。假設用戶類是某種描述用戶的POJO。

public class UserStore implements Thread.UncaughtExceptionHandler { 
private static volatile UserStore instance; 
private static Thread cleanUpThread; 
private static Map<String, TimeStampedToken<User>> tokenMap = new HashMap<String, TimeStampedToken<User>>(); 
public static UserStore getInstance() { 
    if (instance == null) { 
     synchronized(UserStore.class) { 
      if (instance == null) { 
       instance = new UserStore(); 
       cleanUpThread = new Thread(new CleanUpWorker()); 
       cleanUpThread.setUncaughtExceptionHandler(instance); 
       cleanUpThread.start(); 
      } 
     } 
    } 
    return instance; 
} 
public void uncaughtException(Thread thread, Throwable throwable) { 
    if (throwable instanceof ThreadDeath) { 
     cleanUpThread = new Thread(new CleanUpWorker()); 
     cleanUpThread.setUncaughtExceptionHandler(this); 
     cleanUpThread.start(); 
     throw (ThreadDeath)throwable; 
    } 

} 
private static class CleanUpWorker implements Runnable { 
    private static final long CLEANUP_CYCLE_MS = 300000; 
    private static final long OBJECT_LIVE_TIME = 299900; 
    public void run() { 
     long sleepRemaining; 
     long sleepStart = System.currentTimeMillis(); 
     sleepRemaining = CLEANUP_CYCLE_MS; 
     while (true) { 
      try { 
       sleepStart = System.currentTimeMillis(); 
       Thread.sleep(sleepRemaining); 
       cleanUp(); 
       sleepRemaining = CLEANUP_CYCLE_MS; 
      } catch (InterruptedException e) { 
       sleepRemaining = System.currentTimeMillis() - sleepStart; 
      } 
     } 
    } 
    private void cleanUp() { 
     Long currentTime = System.currentTimeMillis(); 
     synchronized(tokenMap) { 
      for (String user : tokenMap.keySet()) { 
       TimeStampedToken<User> tok = tokenMap.get(user); 
       if (tok.accessed + OBJECT_LIVE_TIME < currentTime) { 
        tokenMap.remove(user); 
       } 
      } 
     } 
    } 

} 
public void addToken(User tok) { 
    synchronized(tokenMap) { 
     tokenMap.put(tok.getUserId(), new TimeStampedToken<User>(tok)); 
    } 
} 
public User getToken(String userId) { 
    synchronized(tokenMap) { 
     TimeStampedToken<User> user = tokenMap.get(userId); 
     if (user != null) { 
      user.accessed = System.currentTimeMillis(); 
      return user.payload; 
     } else { 
      return null; 
     } 

    } 
} 
private static class TimeStampedToken<E> { 
    public TimeStampedToken(E payload) { 
     this.payload = payload; 
    } 
    public long accessed = System.currentTimeMillis(); 
    public E payload; 
} 
}

來源

2011-12-21 U Mad

究竟是什麼*問題，你的緩存類是做什麼的？它工作不正確（功能上）？或者它比你想要的慢（導致POST花費太長時間）？如果是這樣，哪種方法調用花費太多時間？ – ArjunShankar 2011-12-21 11:19:39

爲什麼只有在明確告知停止時才重新啓動線程？ – 2011-12-21 11:19:53

我看起來像你試圖實現一個有效期限的緩存。有很多簡單的方法來實現這一點，或者你可以使用已經這樣做的庫。 – 2011-12-21 11:21:15

下面是我如何接近它。使用多線程代碼，簡單性通常是最好的方法，因爲它更可能工作。

（第三個參數的LinkedHashMap的true意味着，在這個地圖迭代器遵循訪問的順序而不是插入的順序）

public enum UserStore { 
    ; 

    interface User { 
     String getUserId(); 
    } 

    // a LRU cache with a timestamp. 
    private static final Map<String, TimeStampedToken<User>> tokenMap = new LinkedHashMap<String, TimeStampedToken<User>>(16, 0.7f, true); 
    private static final long OBJECT_LIVE_TIME = 299900; 

    public static synchronized void addToken(User tok) { 
     final long now = System.currentTimeMillis(); 
     // clean up as we go 
     for (Iterator<Map.Entry<String, TimeStampedToken<User>>> iter = tokenMap.entrySet().iterator(); iter.hasNext();) { 
      final Map.Entry<String, TimeStampedToken<User>> next = iter.next(); 
      if (next.getValue().accessed + OBJECT_LIVE_TIME >= now) 
       // the map is ordered by access time so there are no more to clean up. 
       break; 
      iter.remove(); 
     } 
     // add a new entry 
     tokenMap.put(tok.getUserId(), new TimeStampedToken<User>(tok, now)); 
    } 

    public static synchronized User getToken(String userId) { 
     final long now = System.currentTimeMillis(); 
     TimeStampedToken<User> user = tokenMap.get(userId); 
     if (user == null) 
      return null; 

     user.accessed = now; 
     return user.payload; 
    } 

    static class TimeStampedToken<E> { 
     long accessed; 
     final E payload; 

     TimeStampedToken(E payload, long now) { 
      this.payload = payload; 
      accessed = now; 
     } 
    } 
}

來源

2011-12-21 11:33:17

這行看起來怪我......

sleepRemaining = System.currentTimeMillis（） - sleepStart;

...當然，它應該是...

sleepRemaining = CLEANUP_CYCLE_MS - （System.currentTimeMillis的（） - sleepStart）;

來源

2011-12-21 11:36:04

這段代碼中的錯誤在哪裏？

回答

相關問題