我认为您可以利用 javascript 在上下文中是单线程的这一事实,即使使用异步 chrome.storage API,也可以在没有锁的情况下进行管理。只要您不使用 chrome.storage.sync,那就是 - 如果云端可能有变化,也可能没有变化,我认为所有的赌注都没有了。
我会做这样的事情(即刻写下,未经测试,无错误处理):
var getTask = (function() {
// Private list of requests.
var callbackQueue = [];
// This function is called when chrome.storage.local.set() has
// completed storing the updated task list.
var tasksWritten = function(nComplete) {
// Remove completed requests from the queue.
callbackQueue = callbackQueue.slice(nComplete);
// Handle any newly arrived requests.
if (callbackQueue.length)
chrome.storage.local.get('tasks', distributeTasks);
};
// This function is called via chrome.storage.local.get() with the
// task list.
var distributeTasks = function(items) {
// Invoke callbacks with tasks.
var tasks = items['tasks'];
for (var i = 0; i < callbackQueue.length; ++i)
callbackQueue[i](tasks[i] || null);
// Update and store the task list. Pass the number of requests
// handled as an argument to the set() handler because the queue
// length may change by the time the handler is invoked.
chrome.storage.local.set(
{ 'tasks': tasks.slice(callbackQueue.length) },
function() {
tasksWritten(callbackQueue.length);
}
);
};
// This is the public function task consumers call to get a new
// task. The task is returned via the callback argument.
return function(callback) {
if (callbackQueue.push(callback) === 1)
chrome.storage.local.get('tasks', distributeTasks);
};
})();
这会将来自消费者的任务请求作为回调存储在本地内存的队列中。当一个新请求到达时,回调被添加到队列中,并且如果这是队列中唯一的请求,则获取任务列表。否则我们可以假设队列已经被处理(这是一个隐式锁,只允许一个执行链访问任务列表)。
获取任务列表时,将任务分配给请求。请注意,如果在获取完成之前已经有更多请求到达,则可能有多个请求。如果请求多于任务,则此代码仅将 null 传递给回调。要在更多任务到达之前阻止请求,请保留未使用的回调并在添加任务时重新启动请求处理。如果任务可以动态生成和消耗,请记住,那里也需要防止竞争条件,但此处未显示。
在存储更新的任务列表之前,防止再次读取任务列表很重要。为此,在更新完成之前不会从队列中删除请求。然后我们需要确保处理同时到达的所有请求(可以将对 chrome.storage.local.get() 的调用短路,但为了简单起见,我这样做了)。
这种方法应该非常有效,因为它应该尽量减少对任务列表的更新,同时仍然尽可能快地响应。没有显式锁定或等待。如果您在其他上下文中有任务使用者,请设置调用 getTask() 函数的 chrome.extension 消息处理程序。