Thread.cpp

/***************************************************************************
    The Base Framework (Test Suite)
    A framework for developing platform independent applications

    See COPYRIGHT.txt for details.

    This framework is distributed in the hope that it will be useful,
    but WITHOUT ANY WARRANTY; without even the implied warranty of
    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.

    For the licensing terms refer to the file 'LICENSE'.
 ***************************************************************************/

#include <base/Application.h>
#include <base/string/FormatOutputStream.h>
#include <base/concurrency/Thread.h>
#include <base/concurrency/ExclusiveSynchronize.h>

using namespace com::azure::dev::base;

SpinLock lock;

class MyThread : public Runnable {
private:

  char value = 0;
  unsigned int count = 0;
public:

  MyThread(char _value, unsigned int _count)
    : value(_value), count(_count)
  {
  }

  void run()
  {
    Thread::setThreadName("MyThread");
    
    {
      ExclusiveSynchronize<SpinLock> exclusiveSyncrhonize(lock);
      fout << "Written by MyThread object" << ENDL;
    }

    while (count--) {
      {
        ExclusiveSynchronize<SpinLock> exclusiveSyncrhonize(lock);
        fout << value;
      }
      Thread::yield();
    }
  }

};

class ThreadApplication : public Application {
private:

  static const unsigned int MAJOR_VERSION = 1;
  static const unsigned int MINOR_VERSION = 0;
public:

  ThreadApplication()
    : Application(MESSAGE("Thread"))
  {
  }

  void main()
  {
#if (_COM_AZURE_DEV__BASE__OS == _COM_AZURE_DEV__BASE__WASI) || \
    (_COM_AZURE_DEV__BASE__ARCH == _COM_AZURE_DEV__BASE__SPARC64) // setup_rt_frame: not implemented
    return;
#endif

    fout << getFormalName() << " version "
         << MAJOR_VERSION << '.' << MINOR_VERSION << EOL
         << "The Base Framework (Test Suite)" << EOL
         << ENDL;
    
    MyThread myThreadA('A', 4096);
    MyThread myThreadB('B', 4096);

    Thread myContextA(&myThreadA);
    Thread myContextB(&myThreadB);

    fout << "Starting threads..." << ENDL;
    myContextA.start();
    myContextB.start();

    fout << "Waiting for threads to complete..." << ENDL;
    myContextA.join();
    myContextB.join();
  }
};

APPLICATION_STUB(ThreadApplication);