1 /* 2 * Copyright (C) 2014 The Android Open Source Project 3 * 4 * Licensed under the Apache License, Version 2.0 (the "License"); 5 * you may not use this file except in compliance with the License. 6 * You may obtain a copy of the License at 7 * 8 * http://www.apache.org/licenses/LICENSE-2.0 9 * 10 * Unless required by applicable law or agreed to in writing, software 11 * distributed under the License is distributed on an "AS IS" BASIS, 12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 13 * See the License for the specific language governing permissions and 14 * limitations under the License. 15 */ 16 17 #ifndef ART_RUNTIME_GC_TASK_PROCESSOR_H_ 18 #define ART_RUNTIME_GC_TASK_PROCESSOR_H_ 19 20 #include <memory> 21 #include <set> 22 23 #include "base/mutex.h" 24 #include "runtime_globals.h" 25 #include "thread_pool.h" 26 27 namespace art { 28 namespace gc { 29 30 class HeapTask : public SelfDeletingTask { 31 public: HeapTask(uint64_t target_run_time)32 explicit HeapTask(uint64_t target_run_time) : target_run_time_(target_run_time) { 33 } GetTargetRunTime()34 uint64_t GetTargetRunTime() const { 35 return target_run_time_; 36 } 37 38 private: 39 // Update the updated_target_run_time_, the task processor will re-insert the task when it is 40 // popped and update the target_run_time_. SetTargetRunTime(uint64_t new_target_run_time)41 void SetTargetRunTime(uint64_t new_target_run_time) { 42 target_run_time_ = new_target_run_time; 43 } 44 45 // Time in ns at which we want the task to run. 46 uint64_t target_run_time_; 47 48 friend class TaskProcessor; 49 DISALLOW_IMPLICIT_CONSTRUCTORS(HeapTask); 50 }; 51 52 // Used to process GC tasks (heap trim, heap transitions, concurrent GC). 53 class TaskProcessor { 54 public: 55 TaskProcessor(); 56 virtual ~TaskProcessor(); 57 void AddTask(Thread* self, HeapTask* task) REQUIRES(!lock_); 58 HeapTask* GetTask(Thread* self) REQUIRES(!lock_); 59 void Start(Thread* self) REQUIRES(!lock_); 60 // Stop tells the RunAllTasks to finish up the remaining tasks as soon as 61 // possible then return. 62 void Stop(Thread* self) REQUIRES(!lock_); 63 void RunAllTasks(Thread* self) REQUIRES(!lock_); 64 bool IsRunning() const REQUIRES(!lock_); 65 void UpdateTargetRunTime(Thread* self, HeapTask* target_time, uint64_t new_target_time) 66 REQUIRES(!lock_); 67 Thread* GetRunningThread() const REQUIRES(!lock_); 68 69 private: 70 class CompareByTargetRunTime { 71 public: operator()72 bool operator()(const HeapTask* a, const HeapTask* b) const { 73 return a->GetTargetRunTime() < b->GetTargetRunTime(); 74 } 75 }; 76 77 mutable Mutex lock_ DEFAULT_MUTEX_ACQUIRED_AFTER; 78 ConditionVariable cond_ GUARDED_BY(lock_); 79 bool is_running_ GUARDED_BY(lock_); 80 std::multiset<HeapTask*, CompareByTargetRunTime> tasks_ GUARDED_BY(lock_); 81 Thread* running_thread_ GUARDED_BY(lock_); 82 83 DISALLOW_COPY_AND_ASSIGN(TaskProcessor); 84 }; 85 86 } // namespace gc 87 } // namespace art 88 89 #endif // ART_RUNTIME_GC_TASK_PROCESSOR_H_ 90