Google App Engine。如何使用memcache或數據存儲進行同步操作？

Question

我的主要目標是能夠有一些同步的方法，不應該由其他線程訪問，直到它完成。 如果我有通常的VM - 我會將此方法標記爲synchronized。 但在GAE中，我有多個實例。 我讀過的所有文章都說我應該使用memcache或數據存儲。 但究竟如何？

Answer 1

通常情況下，答案是重新設計的功能，所以它不需要全局同步。即使你設法同步它，它也是一個瓶頸。

你可能最好在後端實現它;你可以指定一個後端，並讓你的函數調用對後端的請求。您也可以使用memcache或數據存儲作爲信號量，但所有這些都會給您帶來糟糕的性能。

Answer 2

其實我並沒有使用那種同步。 一旦我做到了。它似乎工作得很好。 下面是一個例子

String syncKey = "Sync:" + req.getRequestURI(); 
boolean lockAcquired = false; 
try { 
    lockAcquired = acquireLock(syncKey, 5000L); 
    if (!lockAcquired) { 
    return; 
    } 
    // do something here 

} finally { 
    if (lockAcquired) { 
    memcacheService.delete(syncKey); 
    } 
} 


public boolean acquireLock(String syncKey, long maxwait) { 
    long start = System.currentTimeMillis(); 
    while (true) { 
    if (memcacheService.increment(syncKey, 1L, 0L) == 1L) { 
     return true; 
    } 
    if (System.currentTimeMillis() - start > maxwait) { 
     return false; 
    } 
    try { 
     Thread.sleep(100L); 
    } catch (InterruptedException e) { 
    } 
    } 
} 

一般我使用更簡單的同步。它讓我有機會只運行一段代碼。

final long now = System.currentTimeMillis()/(60L * 1000L); // expire every minute 
if (memcacheService.increment("VoteRemoveOldTask" + now, 1L, 1L) == 1L) { 
    QueueFactory.getDefaultQueue().add(
     TaskOptions.Builder.withDefaults().url(VoteRemoveOldTask.URL)); 
}