cond_select.C

#include <unistd.h>
#include <string>
#include <iostream>

#include <archon/util/exception.H>
#include <archon/util/thread.H>

using namespace std;
using namespace Archon::Utilities;

struct T: Thread
{
  Mutex m;
  Condition c;

  T(): c(m) {}
        
  void main()
  {
    fd_set r, w, x;
    FD_ZERO(&r);
    FD_ZERO(&w);
    FD_ZERO(&x);
    FD_SET(0, &r);
    Time t = Time::now();
    t += Time(8.0);
    char b[1024];
    for(;;)
    {
      int n;
      {
        Mutex::Lock l(m);
        n = c.select(1, &r, &w, &x, t);
      }
      if(n==-1)
      {
        cerr << "INTERRUPTED\n";
        //break;
      }
      else if(n==0)
      {
        cerr << "TIMEOUT\n";
        break;
      }
      else
      {
        n = read(0, b, 1024);
        if(!n) break;
        cerr << "> " << string(b, n);
      }
    }
    cerr << "QUIT\n";
  }

  ~T()
  {
    wait();
  }
};

int main()
{
  set_unexpected(Exception::terminal<exceptionCatchInfo>);
  set_terminate (Exception::terminal<exceptionCatchInfo>);

  Ref<T> t = new T;

  Thread::start(t);

  for(unsigned i=0; i<3; ++i)
  {
    Thread::sleep(Time(1.0));
    cerr << "--" << i << "--\n";
  }

  t->terminate();

  /*
  t.c.notifyAll();
  Thread::sleep(Time(1.0));
  t.c.notifyAll();
  Thread::sleep(Time(1.0));
  t.c.notifyAll();
  Thread::sleep(Time(1.0));
  t.c.notifyAll();
  */
        
  t->wait();

  return 0;
}

---