ThreadQueue.h

Go to the documentation of this file.

#ifndef FWCore_MessageService_ThreadQueue_h
#define FWCore_MessageService_ThreadQueue_h
// -*- C++ -*-
//
// Package:     MessageService
// Class  :     ThreadQueue
//
//
// Original Author:  mf and cdj
//         Created:  Fri Aug  7 10:19:58 CDT 2009
//

#include "FWCore/MessageLogger/interface/MessageLoggerQ.h"
#include "FWCore/Utilities/interface/SingleConsumerQ.h"

namespace edm {
  namespace service {

    class ThreadQueue {
    public:
      ThreadQueue();
      virtual ~ThreadQueue();

      // ---------- const member functions ---------------------

      // ---------- static member functions --------------------

      // ---------- member functions ---------------------------

      // ---  obtain a message from the queue:
      void consume(MessageLoggerQ::OpCode& opcode, void*& operand);

      // ---  place a message onto the queue:
      void produce(MessageLoggerQ::OpCode opcode, void* operand);

    private:
      ThreadQueue(const ThreadQueue&) = delete;  // stop default

      const ThreadQueue& operator=(const ThreadQueue&) = delete;  // stop default

      // ---------- member data --------------------------------

      // --- buffer parameters:  (were private but needed by MainTrhreadMLscribe
      static const int buf_depth = 500;
      static const int buf_size = sizeof(MessageLoggerQ::OpCode) + sizeof(void*);
      SingleConsumerQ m_buf;
    };

  }  // end namespace service
}  // end namespace edm

#endif