OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 The Chromium 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 #include "base/threading/sequenced_worker_pool.h" | 5 #include "base/threading/sequenced_worker_pool.h" |
6 | 6 |
7 #include <list> | 7 #include <list> |
8 #include <map> | 8 #include <map> |
9 #include <set> | 9 #include <set> |
10 #include <vector> | 10 #include <vector> |
(...skipping 671 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
682 | 682 |
683 bool SequencedWorkerPool::PostSequencedWorkerTaskWithShutdownBehavior( | 683 bool SequencedWorkerPool::PostSequencedWorkerTaskWithShutdownBehavior( |
684 SequenceToken sequence_token, | 684 SequenceToken sequence_token, |
685 const tracked_objects::Location& from_here, | 685 const tracked_objects::Location& from_here, |
686 const Closure& task, | 686 const Closure& task, |
687 WorkerShutdown shutdown_behavior) { | 687 WorkerShutdown shutdown_behavior) { |
688 return inner_->PostTask(NULL, sequence_token, shutdown_behavior, | 688 return inner_->PostTask(NULL, sequence_token, shutdown_behavior, |
689 from_here, task); | 689 from_here, task); |
690 } | 690 } |
691 | 691 |
| 692 bool SequencedWorkerPool::PostDelayedTask( |
| 693 const tracked_objects::Location& from_here, |
| 694 const Closure& task, |
| 695 int64 delay_ms) { |
| 696 // TODO(akalin): Add support for non-zero delays. |
| 697 DCHECK_EQ(delay_ms, 0); |
| 698 return PostWorkerTask(from_here, task); |
| 699 } |
| 700 |
| 701 bool SequencedWorkerPool::PostDelayedTask( |
| 702 const tracked_objects::Location& from_here, |
| 703 const Closure& task, |
| 704 TimeDelta delay) { |
| 705 // TODO(akalin): Add support for non-zero delays. |
| 706 DCHECK_EQ(delay.InMillisecondsRoundedUp(), 0); |
| 707 return PostWorkerTask(from_here, task); |
| 708 } |
| 709 |
| 710 bool SequencedWorkerPool::RunsTasksOnCurrentThread() const { |
| 711 // TODO(akalin): Keep track of the thread IDs of our worker threads |
| 712 // and use those to implement this function. |
| 713 NOTREACHED(); |
| 714 return true; |
| 715 } |
| 716 |
692 void SequencedWorkerPool::FlushForTesting() { | 717 void SequencedWorkerPool::FlushForTesting() { |
693 inner_->FlushForTesting(); | 718 inner_->FlushForTesting(); |
694 } | 719 } |
695 | 720 |
696 void SequencedWorkerPool::Shutdown() { | 721 void SequencedWorkerPool::Shutdown() { |
697 inner_->Shutdown(); | 722 inner_->Shutdown(); |
698 } | 723 } |
699 | 724 |
700 void SequencedWorkerPool::SetTestingObserver(TestingObserver* observer) { | 725 void SequencedWorkerPool::SetTestingObserver(TestingObserver* observer) { |
701 inner_->SetTestingObserver(observer); | 726 inner_->SetTestingObserver(observer); |
702 } | 727 } |
703 | 728 |
704 } // namespace base | 729 } // namespace base |
OLD | NEW |