#include "src/libplatform/worker-thread.h"
namespace v8 {
-namespace internal {
+namespace platform {
const int DefaultPlatform::kMaxThreadPoolSize = 4;
delete task;
}
-} } // namespace v8::internal
+} } // namespace v8::platform
#include "src/libplatform/task-queue.h"
namespace v8 {
-namespace internal {
+namespace platform {
class TaskQueue;
class Thread;
};
-} } // namespace v8::internal
+} } // namespace v8::platform
#endif // V8_LIBPLATFORM_DEFAULT_PLATFORM_H_
#include "src/base/logging.h"
namespace v8 {
-namespace internal {
+namespace platform {
TaskQueue::TaskQueue() : process_queue_semaphore_(0), terminated_(false) {}
process_queue_semaphore_.Signal();
}
-} } // namespace v8::internal
+} } // namespace v8::platform
class Task;
-namespace internal {
+namespace platform {
class TaskQueue {
public:
DISALLOW_COPY_AND_ASSIGN(TaskQueue);
};
-} } // namespace v8::internal
+} } // namespace v8::platform
#endif // V8_LIBPLATFORM_TASK_QUEUE_H_
#include "src/libplatform/task-queue.h"
namespace v8 {
-namespace internal {
+namespace platform {
WorkerThread::WorkerThread(TaskQueue* queue)
: Thread("V8 WorkerThread"), queue_(queue) {
}
}
-} } // namespace v8::internal
+} } // namespace v8::platform
namespace v8 {
-namespace internal {
+namespace platform {
class TaskQueue;
DISALLOW_COPY_AND_ASSIGN(WorkerThread);
};
-} } // namespace v8::internal
+} } // namespace v8::platform
#endif // V8_LIBPLATFORM_WORKER_THREAD_H_
if (isolate->IsInitialized()) return true;
#ifdef V8_USE_DEFAULT_PLATFORM
- DefaultPlatform* platform = static_cast<DefaultPlatform*>(platform_);
+ platform::DefaultPlatform* platform =
+ static_cast<platform::DefaultPlatform*>(platform_);
platform->SetThreadPoolSize(isolate->max_available_threads());
// We currently only start the threads early, if we know that we'll use them.
if (FLAG_job_based_sweeping) platform->EnsureInitialized();
Sampler::TearDown();
#ifdef V8_USE_DEFAULT_PLATFORM
- DefaultPlatform* platform = static_cast<DefaultPlatform*>(platform_);
+ platform::DefaultPlatform* platform =
+ static_cast<platform::DefaultPlatform*>(platform_);
platform_ = NULL;
delete platform;
#endif
base::OS::Initialize(FLAG_random_seed, FLAG_hard_abort, FLAG_gc_fake_mmap);
#ifdef V8_USE_DEFAULT_PLATFORM
- platform_ = new DefaultPlatform;
+ platform_ = new platform::DefaultPlatform;
#endif
Sampler::SetUp();
CpuFeatures::Probe(false);
#include "test/cctest/test-libplatform.h"
using namespace v8::internal;
+using namespace v8::platform;
TEST(TaskQueueBasic) {
#include "test/cctest/test-libplatform.h"
using namespace v8::internal;
+using namespace v8::platform;
TEST(WorkerThread) {
#include "test/cctest/cctest.h"
using namespace v8::internal;
+using namespace v8::platform;
class TaskCounter {
public: