Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(133)

Side by Side Diff: src/compiler-dispatcher/compiler-dispatcher.h

Issue 2614433002: Revert of Use background tasks for the compiler dispatcher (Closed)
Patch Set: Created 3 years, 11 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
« no previous file with comments | « src/cancelable-task.cc ('k') | src/compiler-dispatcher/compiler-dispatcher.cc » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 // Copyright 2016 the V8 project authors. All rights reserved. 1 // Copyright 2016 the V8 project authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 #ifndef V8_COMPILER_DISPATCHER_COMPILER_DISPATCHER_H_ 5 #ifndef V8_COMPILER_DISPATCHER_COMPILER_DISPATCHER_H_
6 #define V8_COMPILER_DISPATCHER_COMPILER_DISPATCHER_H_ 6 #define V8_COMPILER_DISPATCHER_COMPILER_DISPATCHER_H_
7 7
8 #include <map> 8 #include <map>
9 #include <memory> 9 #include <memory>
10 #include <unordered_set>
11 #include <utility> 10 #include <utility>
12 11
13 #include "src/base/macros.h" 12 #include "src/base/macros.h"
14 #include "src/base/platform/condition-variable.h"
15 #include "src/base/platform/mutex.h"
16 #include "src/globals.h" 13 #include "src/globals.h"
17 #include "testing/gtest/include/gtest/gtest_prod.h" 14 #include "testing/gtest/include/gtest/gtest_prod.h"
18 15
19 namespace v8 { 16 namespace v8 {
20 17
21 class Platform; 18 class Platform;
22 19
23 namespace internal { 20 namespace internal {
24 21
25 class CancelableTaskManager;
26 class CompilerDispatcherJob; 22 class CompilerDispatcherJob;
27 class CompilerDispatcherTracer; 23 class CompilerDispatcherTracer;
28 class Isolate; 24 class Isolate;
29 class SharedFunctionInfo; 25 class SharedFunctionInfo;
30 26
31 template <typename T> 27 template <typename T>
32 class Handle; 28 class Handle;
33 29
34 // The CompilerDispatcher uses a combination of idle tasks and background tasks 30 // The CompilerDispatcher uses a combination of idle tasks and background tasks
35 // to parse and compile lazily parsed functions. 31 // to parse and compile lazily parsed functions.
36 //
37 // As both parsing and compilation currently requires a preparation and
38 // finalization step that happens on the main thread, every task has to be
39 // advanced during idle time first. Depending on the properties of the task, it
40 // can then be parsed or compiled on either background threads, or during idle
41 // time. Last, it has to be finalized during idle time again.
42 //
43 // CompilerDispatcher::jobs_ maintains the list of all CompilerDispatcherJobs
44 // the CompilerDispatcher knows about.
45 //
46 // CompilerDispatcher::pending_background_jobs_ contains the set of
47 // CompilerDispatcherJobs that can be processed on a background thread.
48 //
49 // CompilerDispatcher::running_background_jobs_ contains the set of
50 // CompilerDispatcherJobs that are currently being processed on a background
51 // thread.
52 //
53 // CompilerDispatcher::DoIdleWork tries to advance as many jobs out of jobs_ as
54 // possible during idle time. If a job can't be advanced, but is suitable for
55 // background processing, it fires off background threads.
56 //
57 // CompilerDispatcher::DoBackgroundWork advances one of the pending jobs, and
58 // then spins of another idle task to potentially do the final step on the main
59 // thread.
60 class V8_EXPORT_PRIVATE CompilerDispatcher { 32 class V8_EXPORT_PRIVATE CompilerDispatcher {
61 public: 33 public:
62 enum class BlockingBehavior { kBlock, kDontBlock }; 34 enum class BlockingBehavior { kBlock, kDontBlock };
63 35
64 CompilerDispatcher(Isolate* isolate, Platform* platform, 36 CompilerDispatcher(Isolate* isolate, Platform* platform,
65 size_t max_stack_size); 37 size_t max_stack_size);
66 ~CompilerDispatcher(); 38 ~CompilerDispatcher();
67 39
68 // Returns true if a job was enqueued. 40 // Returns true if a job was enqueued.
69 bool Enqueue(Handle<SharedFunctionInfo> function); 41 bool Enqueue(Handle<SharedFunctionInfo> function);
70 42
71 // Returns true if there is a pending job for the given function. 43 // Returns true if there is a pending job for the given function.
72 bool IsEnqueued(Handle<SharedFunctionInfo> function) const; 44 bool IsEnqueued(Handle<SharedFunctionInfo> function) const;
73 45
74 // Blocks until the given function is compiled (and does so as fast as 46 // Blocks until the given function is compiled (and does so as fast as
75 // possible). Returns true if the compile job was succesful. 47 // possible). Returns true if the compile job was succesful.
76 bool FinishNow(Handle<SharedFunctionInfo> function); 48 bool FinishNow(Handle<SharedFunctionInfo> function);
77 49
78 // Aborts a given job. Blocks if requested. 50 // Aborts a given job. Blocks if requested.
79 void Abort(Handle<SharedFunctionInfo> function, BlockingBehavior blocking); 51 void Abort(Handle<SharedFunctionInfo> function, BlockingBehavior blocking);
80 52
81 // Aborts all jobs. Blocks if requested. 53 // Aborts all jobs. Blocks if requested.
82 void AbortAll(BlockingBehavior blocking); 54 void AbortAll(BlockingBehavior blocking);
83 55
84 private: 56 private:
85 FRIEND_TEST(CompilerDispatcherTest, IdleTaskSmallIdleTime); 57 FRIEND_TEST(CompilerDispatcherTest, IdleTaskSmallIdleTime);
86 FRIEND_TEST(IgnitionCompilerDispatcherTest, CompileOnBackgroundThread);
87 FRIEND_TEST(IgnitionCompilerDispatcherTest, FinishNowWithBackgroundTask);
88 58
89 typedef std::multimap<std::pair<int, int>, 59 typedef std::multimap<std::pair<int, int>,
90 std::unique_ptr<CompilerDispatcherJob>> 60 std::unique_ptr<CompilerDispatcherJob>>
91 JobMap; 61 JobMap;
92 class BackgroundTask;
93 class IdleTask; 62 class IdleTask;
94 63
95 void WaitForJobIfRunningOnBackground(CompilerDispatcherJob* job);
96 bool IsEnabled() const; 64 bool IsEnabled() const;
97 JobMap::const_iterator GetJobFor(Handle<SharedFunctionInfo> shared) const; 65 JobMap::const_iterator GetJobFor(Handle<SharedFunctionInfo> shared) const;
98 void ConsiderJobForBackgroundProcessing(CompilerDispatcherJob* job);
99 void ScheduleMoreBackgroundTasksIfNeeded();
100 void ScheduleIdleTaskFromAnyThread();
101 void ScheduleIdleTaskIfNeeded(); 66 void ScheduleIdleTaskIfNeeded();
102 void DoBackgroundWork();
103 void DoIdleWork(double deadline_in_seconds); 67 void DoIdleWork(double deadline_in_seconds);
104 68
105 Isolate* isolate_; 69 Isolate* isolate_;
106 Platform* platform_; 70 Platform* platform_;
107 size_t max_stack_size_; 71 size_t max_stack_size_;
108 std::unique_ptr<CompilerDispatcherTracer> tracer_; 72 std::unique_ptr<CompilerDispatcherTracer> tracer_;
109 73
110 std::unique_ptr<CancelableTaskManager> task_manager_; 74 bool idle_task_scheduled_;
111 75
112 // Mapping from (script id, function literal id) to job. We use a multimap, 76 // Mapping from (script id, function literal id) to job. We use a multimap,
113 // as script id is not necessarily unique. 77 // as script id is not necessarily unique.
114 JobMap jobs_; 78 JobMap jobs_;
115 79
116 // The following members can be accessed from any thread. Methods need to hold
117 // the mutex |mutex_| while accessing them.
118 base::Mutex mutex_;
119
120 bool idle_task_scheduled_;
121
122 // Number of currently scheduled BackgroundTask objects.
123 size_t num_scheduled_background_tasks_;
124
125 // The set of CompilerDispatcherJobs that can be advanced on any thread.
126 std::unordered_set<CompilerDispatcherJob*> pending_background_jobs_;
127
128 // The set of CompilerDispatcherJobs currently processed on background
129 // threads.
130 std::unordered_set<CompilerDispatcherJob*> running_background_jobs_;
131
132 // If not nullptr, then the main thread waits for the task processing
133 // this job, and blocks on the ConditionVariable main_thread_blocking_signal_.
134 CompilerDispatcherJob* main_thread_blocking_on_job_;
135 base::ConditionVariable main_thread_blocking_signal_;
136
137 DISALLOW_COPY_AND_ASSIGN(CompilerDispatcher); 80 DISALLOW_COPY_AND_ASSIGN(CompilerDispatcher);
138 }; 81 };
139 82
140 } // namespace internal 83 } // namespace internal
141 } // namespace v8 84 } // namespace v8
142 85
143 #endif // V8_COMPILER_DISPATCHER_COMPILER_DISPATCHER_H_ 86 #endif // V8_COMPILER_DISPATCHER_COMPILER_DISPATCHER_H_
OLDNEW
« no previous file with comments | « src/cancelable-task.cc ('k') | src/compiler-dispatcher/compiler-dispatcher.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698