// g++ -g3 -ggdb -O0 -D_REENTRANT=1 sp-test.cpp -o sp-test.exe -lpthread

#include <iostream>
using std::cout;
using std::cerr;
using std::endl;
using std::ostream;

#include <string>
using std::string;

#include <vector>
using std::vector;

#include <sstream>
using std::stringstream;
using std::istringstream;
using std::ostringstream;

#include <boost/shared_ptr.hpp>
using boost::shared_ptr;

#include <stdlib.h>
#include <error.h>
#include <errno.h>
#include <pthread.h>
#include <string.h>

#if !defined(nullptr_t)
# define nullptr NULL
#endif

#if !defined(byte)
typedef unsigned char byte;
#endif

struct Block
{
    explicit Block() { }
    virtual ~Block() { }
    byte block[24];
};

static const unsigned int THREAD_COUNT = 128;
static const unsigned int ITERATIONS = 2048;

void* WorkerThreadProc(void* param);
void Message(ostream& strm, const string& msg);

typedef shared_ptr<Block> BlockPtr;

static const unsigned int SIZE = 128;
BlockPtr blocks[SIZE];

int main(int, char**)
{
  srand(0);

  pthread_t threads[THREAD_COUNT];

  // *** Worker Threads ***
  for(unsigned int i=0; i<THREAD_COUNT; i++)
    {
      int ret = pthread_create(&threads[i], nullptr, WorkerThreadProc, (void*)i);
      if(0 != ret /*success*/)
        {
          ostringstream oss;
          oss << "pthread_create failed (thread " << i << "): " << strerror(errno);
          Message(cerr, oss.str());
        }
    }

  for(unsigned int i=0; i<THREAD_COUNT; i++)
    {
      int ret = pthread_join(threads[i], nullptr);
      if(0 != ret /*success*/)
        {
          ostringstream oss;
          oss << "pthread_join failed (thread " << i << "): " << strerror(errno);
          Message(cerr, oss.str());
        }
    }
}

void* WorkerThreadProc(void* param)
{

  // give up the remainder of this time quantum to help
  // interleave thread creation and execution
  sleep(0);

  for(unsigned int i = 0; i < ITERATIONS; i++)
  {
    int idx1 = rand() % SIZE;
    int idx2 = rand() % SIZE;

    blocks[idx1] = blocks[idx2];
  }

  return (void*)0;
}

void Message(ostream& strm, const string& msg)
{

}