msg.h

Go to the documentation of this file.

// @file msg.h - interthread message passing

#pragma once

#include <deque>
#include "task.h"

namespace mongo {

    namespace task {

        typedef boost::function<void()> lam;

        class Server : public Task {
        public:
            void send(lam);

            Server(string name) : _name(name), rq(false) { }
            virtual ~Server() { }

            void call(const lam&);

            void requeue() { rq = true; }

        protected:
            /* REMINDER : for use in mongod, you will want to have this call Client::initThread(). */
            virtual void starting() { }

        private:
            virtual bool initClient() { return true; }
            virtual string name() const { return _name; }
            void doWork();
            deque<lam> d;
            boost::mutex m;
            boost::condition c;
            string _name;
            bool rq;
        };

    }

}

---

mongodb
Author(s): Nate Koenig
autogenerated on Fri Jan 11 12:15:18 2013