EDK: Add a mojo::test::SimpleTestThread (and use it).

mojo/edk/system/message_pipe_dispatcher_unittest.cc

 // Copyright 2013 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 // NOTE(vtl): Some of these tests are inherently flaky (e.g., if run on a
 // heavily-loaded system). Sorry. |test::EpsilonDeadline()| may be increased to
 // increase tolerance and reduce observed flakiness (though doing so reduces the
 // meaningfulness of the test).
 
 #include "mojo/edk/system/message_pipe_dispatcher.h"
 
 #include <string.h>
 
 #include <limits>
 
 #include "base/memory/ref_counted.h"
 #include "base/memory/scoped_vector.h"
-#include "base/threading/simple_thread.h"
 #include "mojo/edk/system/message_pipe.h"
 #include "mojo/edk/system/test_utils.h"
 #include "mojo/edk/system/waiter.h"
 #include "mojo/edk/system/waiter_test_utils.h"
+#include "mojo/edk/test/simple_test_thread.h"
 #include "mojo/public/cpp/system/macros.h"
 #include "testing/gtest/include/gtest/gtest.h"
 
 namespace mojo {
 namespace system {
 namespace {
 
 const MojoHandleSignals kAllSignals = MOJO_HANDLE_SIGNAL_READABLE |
                                       MOJO_HANDLE_SIGNAL_WRITABLE |
                                       MOJO_HANDLE_SIGNAL_PEER_CLOSED;
@@ skipping 432 matching lines @@
     EXPECT_EQ(0u, hss.satisfiable_signals);
 
     EXPECT_EQ(MOJO_RESULT_OK, d0->Close());
   }
 }
 
 // Stress test -----------------------------------------------------------------
 
 const size_t kMaxMessageSize = 2000;
 
-class WriterThread : public base::SimpleThread {
+class WriterThread : public mojo::test::SimpleTestThread {
  public:
   // |*messages_written| and |*bytes_written| belong to the thread while it's
   // alive.
   WriterThread(scoped_refptr<Dispatcher> write_dispatcher,
                size_t* messages_written,
                size_t* bytes_written)
-      : base::SimpleThread("writer_thread"),
-        write_dispatcher_(write_dispatcher),
+      : write_dispatcher_(write_dispatcher),
         messages_written_(messages_written),
         bytes_written_(bytes_written) {
     *messages_written_ = 0;
     *bytes_written_ = 0;
   }
 
   ~WriterThread() override { Join(); }
 
  private:
   void Run() override {
@@ skipping 22 matching lines @@
                                   MOJO_WRITE_MESSAGE_FLAG_NONE));
   }
 
   const scoped_refptr<Dispatcher> write_dispatcher_;
   size_t* const messages_written_;
   size_t* const bytes_written_;
 
   MOJO_DISALLOW_COPY_AND_ASSIGN(WriterThread);
 };
 
-class ReaderThread : public base::SimpleThread {
+class ReaderThread : public mojo::test::SimpleTestThread {
  public:
   // |*messages_read| and |*bytes_read| belong to the thread while it's alive.
   ReaderThread(scoped_refptr<Dispatcher> read_dispatcher,
                size_t* messages_read,
                size_t* bytes_read)
-      : base::SimpleThread("reader_thread"),
-        read_dispatcher_(read_dispatcher),
+      : read_dispatcher_(read_dispatcher),
         messages_read_(messages_read),
         bytes_read_(bytes_read) {
     *messages_read_ = 0;
     *bytes_read_ = 0;
   }
 
   ~ReaderThread() override { Join(); }
 
  private:
   void Run() override {
@@ skipping 130 matching lines @@
   EXPECT_EQ(total_messages_written, total_messages_read);
   EXPECT_EQ(total_bytes_written, total_bytes_read);
 
   EXPECT_EQ(MOJO_RESULT_OK, d_write->Close());
   EXPECT_EQ(MOJO_RESULT_OK, d_read->Close());
 }
 
 }  // namespace
 }  // namespace system
 }  // namespace mojo