Method exec

gecode/support/thread/thread.cpp:49–72

  Thread::Run* Thread::idle = nullptr;

  void
  Thread::Run::exec(void) {
    while (true) {
      // Execute runnable
      {
        GECODE_ASSUME(r != nullptr);
        Runnable* e = r.exchange(nullptr);
        assert(e != nullptr);
        e->run();
        if (e->todelete()) {
          Terminator* t = e->terminator();
          delete e;
          if (t)
            t->terminated();
        }
      }
      // Put into idle stack
      Thread::m()->acquire();
      n=Thread::idle; Thread::idle=this;
      Thread::m()->release();
      // Wait for next runnable
      e.wait();
    }
  }

  Thread::Run::Run(Runnable* r0) {
#ifdef GECODE_HAS_THREADS