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

Side by Side Diff: runtime/bin/thread_pool.cc

Issue 9112013: Thread pool changes (Closed) Base URL: https://dart.googlecode.com/svn/branches/bleeding_edge/dart
Patch Set: Created 8 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 | Annotate | Revision Log
OLDNEW
1 // Copyright (c) 2012, the Dart project authors. Please see the AUTHORS file 1 // Copyright (c) 2012, the Dart project authors. Please see the AUTHORS file
2 // for details. All rights reserved. Use of this source code is governed by a 2 // for details. All rights reserved. Use of this source code is governed by a
3 // BSD-style license that can be found in the LICENSE file. 3 // BSD-style license that can be found in the LICENSE file.
4 4
5 #include "bin/thread_pool.h" 5 #include "bin/thread_pool.h"
6 6
7 void ThreadPool::Shutdown() { 7 void ThreadPool::Shutdown() {
8 UNIMPLEMENTED(); 8 UNIMPLEMENTED();
9 } 9 }
10 10
11 11
12 void ThreadPool::InsertTask(Task task) { 12 void ThreadPool::InsertTask(Task task) {
13 TaskQueueEntry* entry = new TaskQueueEntry(task); 13 TaskQueueEntry* entry = new TaskQueueEntry(task);
14 queue.Insert(entry); 14 queue.Insert(entry);
15 } 15 }
16 16
17 17
18 Task ThreadPool::WaitForTask() { 18 Task ThreadPool::WaitForTask() {
19 TaskQueueEntry* entry = queue.Remove(); 19 TaskQueueEntry* entry = queue.Remove();
20 if (entry == NULL) { 20 if (entry == NULL) {
21 return -1; 21 return NULL;
22 } 22 }
23 Task task = entry->task(); 23 Task task = entry->task();
24 delete entry; 24 delete entry;
25 return task; 25 return task;
26 } 26 }
27 27
28 28
29 void* ThreadPool::Main(void* args) { 29 void* ThreadPool::Main(void* args) {
30 if (Dart_IsVMFlagSet("trace_thread_pool")) { 30 if (Dart_IsVMFlagSet("trace_thread_pool")) {
31 printf("Thread pool thread started\n"); 31 printf("Thread pool thread started\n");
32 } 32 }
33 ThreadPool* pool = reinterpret_cast<ThreadPool*>(args); 33 ThreadPool* pool = reinterpret_cast<ThreadPool*>(args);
34 while (true) { 34 while (true) {
35 if (Dart_IsVMFlagSet("trace_thread_pool")) { 35 if (Dart_IsVMFlagSet("trace_thread_pool")) {
36 printf("Waiting for task\n"); 36 printf("Waiting for task\n");
37 } 37 }
38 Task task = pool->WaitForTask(); 38 Task task = pool->WaitForTask();
39 if (Dart_IsVMFlagSet("trace_thread_pool")) { 39 (*(pool->task_handler_))(task);
40 printf("Got task %d\n", task);
41 }
42 } 40 }
43 return NULL; 41 return NULL;
44 }; 42 };
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698