opensub.h

Go to the documentation of this file.

#ifndef ABA_OPENSUB_H
#define ABA_OPENSUB_H


#include "abacus/dlist.h"

#ifdef ABACUS_PARALLEL
#include <ace/Synch.h>
#endif

class ABA_MASTER;
class ABA_SUB;

  class  ABA_OPENSUB :  public ABA_ABACUSROOT  {
  friend class ABA_SUB;
  friend class ABA_MASTER;
#ifdef ABACUS_PARALLEL
  friend class ABA_SUBSERVER;
  friend class ABA_PARMASTER;
#endif
    public:

      ABA_OPENSUB(ABA_MASTER *master);

      int number() const;

      bool empty() const;

      double  dualBound() const;
#ifdef ABACUS_PARALLEL

      void terminate();

      ABA_SUB *getSubproblemWithBound(double bound);
      void triggerSelect();
#endif

    private:

      ABA_SUB *select();

      void insert(ABA_SUB *sub);

      void remove(ABA_SUB *sub);

      void prune();

      void updateDualBound();

      ABA_MASTER *master_;
#ifdef ABACUS_PARALLEL

      ABA_DLIST<ABA_SUB*> list_;

      volatile int           n_;

      double        dualBound_;
      mutable ACE_Thread_Mutex        mutex_;
      ACE_Condition<ACE_Thread_Mutex> cond_;
      volatile bool                   terminate_;
      volatile bool                   hasTerminated_;
#else

      ABA_DLIST<ABA_SUB*> list_;

      int           n_;

      double        dualBound_;
#endif
      ABA_OPENSUB(const ABA_OPENSUB &rhs);
      const ABA_OPENSUB &operator=(const ABA_OPENSUB &rhs);
  };


inline int ABA_OPENSUB::number() const
  {
    return n_;
  }

inline bool ABA_OPENSUB::empty() const
  {
    return list_.empty();
  }

#ifdef ABACUS_PARALLEL
inline void ABA_OPENSUB::triggerSelect()
  {
    cond_.signal();
  }
#endif

#endif  // ABA_OPENSUB_H

---