Version 3.28.71.3 (merged r23081)

test/cctest/test-semaphore.cc

 // Copyright 2013 the V8 project authors. All rights reserved.
 // Redistribution and use in source and binary forms, with or without
 // modification, are permitted provided that the following conditions are
 // met:
 //
 //     * Redistributions of source code must retain the above copyright
 //       notice, this list of conditions and the following disclaimer.
 //     * Redistributions in binary form must reproduce the above
 //       copyright notice, this list of conditions and the following
 //       disclaimer in the documentation and/or other materials provided
@@ skipping 21 matching lines @@
 #include "src/base/platform/platform.h"
 #include "test/cctest/cctest.h"
 
 
 using namespace ::v8::internal;
 
 
 class WaitAndSignalThread V8_FINAL : public v8::base::Thread {
  public:
   explicit WaitAndSignalThread(v8::base::Semaphore* semaphore)
-      : Thread("WaitAndSignalThread"), semaphore_(semaphore) {}
+      : Thread(Options("WaitAndSignalThread")), semaphore_(semaphore) {}
   virtual ~WaitAndSignalThread() {}
 
   virtual void Run() V8_OVERRIDE {
     for (int n = 0; n < 1000; ++n) {
       semaphore_->Wait();
       bool result =
           semaphore_->WaitFor(v8::base::TimeDelta::FromMicroseconds(1));
       DCHECK(!result);
       USE(result);
       semaphore_->Signal();
@@ skipping 57 matching lines @@
 static const int kBufferSize = 4096;  // GCD(buffer size, alphabet size) = 1
 static char buffer[kBufferSize];
 static const int kDataSize = kBufferSize * kAlphabetSize * 10;
 
 static v8::base::Semaphore free_space(kBufferSize);
 static v8::base::Semaphore used_space(0);
 
 
 class ProducerThread V8_FINAL : public v8::base::Thread {
  public:
-  ProducerThread() : Thread("ProducerThread") {}
+  ProducerThread() : Thread(Options("ProducerThread")) {}
   virtual ~ProducerThread() {}
 
   virtual void Run() V8_OVERRIDE {
     for (int n = 0; n < kDataSize; ++n) {
       free_space.Wait();
       buffer[n % kBufferSize] = alphabet[n % kAlphabetSize];
       used_space.Signal();
     }
   }
 };
 
 
 class ConsumerThread V8_FINAL : public v8::base::Thread {
  public:
-  ConsumerThread() : Thread("ConsumerThread") {}
+  ConsumerThread() : Thread(Options("ConsumerThread")) {}
   virtual ~ConsumerThread() {}
 
   virtual void Run() V8_OVERRIDE {
     for (int n = 0; n < kDataSize; ++n) {
       used_space.Wait();
       DCHECK_EQ(static_cast<int>(alphabet[n % kAlphabetSize]),
                 static_cast<int>(buffer[n % kBufferSize]));
       free_space.Signal();
     }
   }
 };
 
 
 TEST(ProducerConsumer) {
   ProducerThread producer_thread;
   ConsumerThread consumer_thread;
   producer_thread.Start();
   consumer_thread.Start();
   producer_thread.Join();
   consumer_thread.Join();
 }