blob: 6eea8c018c4b430d8648516330f52ca11399d5b4 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
|
// Copyright (c) 2011 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#ifndef WEBKIT_GLUE_WORKER_TASK_RUNNER_H_
#define WEBKIT_GLUE_WORKER_TASK_RUNNER_H_
#pragma once
#include <map>
#include "base/atomic_sequence_num.h"
#include "base/callback_forward.h"
#include "base/synchronization/lock.h"
#include "base/threading/thread_local.h"
#include "third_party/WebKit/Source/WebKit/chromium/public/WebWorkerRunLoop.h"
#include "webkit/glue/webkit_glue_export.h"
namespace webkit_glue {
class WEBKIT_GLUE_EXPORT WorkerTaskRunner {
public:
WorkerTaskRunner();
void PostTask(int id, const base::Closure& task);
int CurrentWorkerId();
static WorkerTaskRunner* Instance();
class Observer {
public:
virtual ~Observer() {}
virtual void OnWorkerRunLoopStopped() = 0;
};
// Add/Remove an observer that will get notified when the current worker run
// loop is stopping. This observer will not get notified when other threads
// are stopping. It's only valid to call these on a worker thread.
void AddStopObserver(Observer* observer);
void RemoveStopObserver(Observer* observer);
private:
friend class WebKitPlatformSupportImpl;
friend class WorkerTaskRunnerTest;
typedef std::map<int, WebKit::WebWorkerRunLoop> IDToLoopMap;
~WorkerTaskRunner();
void OnWorkerRunLoopStarted(const WebKit::WebWorkerRunLoop& loop);
void OnWorkerRunLoopStopped(const WebKit::WebWorkerRunLoop& loop);
struct ThreadLocalState;
base::ThreadLocalPointer<ThreadLocalState> current_tls_;
base::AtomicSequenceNumber id_sequence_;
IDToLoopMap loop_map_;
base::Lock loop_map_lock_;
};
} // namespace webkit_glue
#endif // WEBKIT_GLUE_WORKER_TASK_RUNNER_H_
|
