Zu machen, wie die Klasse member-Funktion, die als thread-Funktion mit boost

Ich schreiben werde, um eine adapter-Klasse. In dieser Klasse gibt es eine xmlrpc-c server (abyss-server). Ich will den server starten, indem du einen neuen thread, und der thread-Funktion ist die member-Funktion XMLThreadFun().

Wenn ich versuche, verwenden Sie den folgenden code gibt es einen Fehler bei der Zeile an den Konstruktor des Adapters Umsetzung:

/usr/include/boost/bind/bind.hpp:69:37: error: ‘void (Adapter::*)()’ is not a class, struct, or union type

Kann mir jemand sagen, wie man dieses Problem lösen Fehler, oder wie das zu erreichen ist mein Ziel? Ich wirklich zu schätzen.

Unten ist mein code-snippet: 

#ifdef _MSC_VER
#pragma warning( disable : 4503 4355 4786 )
#else
#include "config.h"
#endif

#include "quickfix/FileStore.h"
#include "quickfix/SocketInitiator.h"
#include "quickfix/SessionSettings.h"
#include "Application.h"
#include <string>
#include <iostream>
#include <fstream>
#include "quickfix/SessionID.h"
#include "quickfix/Session.h"
#include "getopt-repl.h"


#include <cassert>
#include <xmlrpc-c/base.hpp>
#include <xmlrpc-c/registry.hpp>
#include <xmlrpc-c/server_abyss.hpp>



#include <boost/thread.hpp>
#include <boost/date_time.hpp>

using namespace std;
class theClient : public xmlrpc_c::method {
public:
    theClient() {}
    theClient(FIX::SocketInitiator* initiator) {
        set<FIX::SessionID> s(initiator->getSessions());
        set<FIX::SessionID>::iterator myIterator;
        for (myIterator = s.begin(); myIterator != s.end(); myIterator++) {
            string str(myIterator->getSenderCompID());
            clientname = str;
        }
    }

    void execute(xmlrpc_c::paramList const& paramList,
        xmlrpc_c::value *   const  retvalP) {
        *retvalP = xmlrpc_c::value_string(clientname);
    }

private:
    string clientname;

};

class Adapter {
private:
    xmlrpc_c::registry myRegistry;
    xmlrpc_c::methodPtr XMLRPCMethodP;
    xmlrpc_c::serverAbyss webServer;
    boost::thread webServerThread;
public:
    void initWebServer(string rpcHost, string rpcPort);
    void XMLThreadFun();
    Adapter(string rpcHost, string rpcPort);
};

Adapter::Adapter(string rpcHost, string rpcPort) : myRegistry(), XMLRPCMethodP(new theClient), webServer(myRegistry, 8181, "/tmp/xmlrpc_log"), webServerThread(boost::bind(&Adapter::XMLThreadFun, this, &webServer))
{
    initWebServer(rpcHost, rpcPort);
}

void Adapter::XMLThreadFun() {
    webServer->run();
}

void Adapter::initWebServer(string rpcHost, string rpcPort) {
    webServerThread.join();
}

InformationsquelleAutor Peiti Li | 2011-07-15

  1. 8

    Müssen Sie die Verwendung von boost::bind Aufruf einer member-Funktion als einen thread.
    So etwas wie 

    class MyClass {
public: 
   void Start();
   void DoStuff( int limit );
};

MyClass foo;
boost::thread thread1( boost::bind( &MyClass::Start, &foo ) );
boost::thread thread2( boost::bind( &MyClass::DoStuff, &foo, 30 ) );
//threads do stuff here
thread1.join();
thread2.join();

    Speziell hier, es sieht aus wie Sie, das würde sich ändern

    webServerThread( boost::bind( &Adapter::XMLThreadFun, this, &webServer)

    zu

    webServerThread( boost::bind( &Adapter::XMLThreadFun, this )
    Tatsächlich, ich benutzt boost::bind. Das Ende von Konstruktor Linie: Netzteil::Netzteil(string rpcHost, string rpcPort) : myRegistry(), XMLRPCMethodP(neue theClient), webServer(myRegistry, 8181, "/tmp/xmlrpc_log"), webServerThread(boost::bind(&Adapter::XMLThreadFun, this, &webServer))
    Ah - deine Argumente passen nicht zusammen. XMLThreadFun nimmt keine Argumente, aber Sie geben einen Zeiger auf den webServer in Ihrem Aufruf.

    InformationsquelleAutor Josh

  2. 5

    Keine Notwendigkeit, die Verwendung von boost::bind

    boost::thread thread2( boost::bind( &MyClass::DoStuff, &foo, 30 ) );

    ist äquivalent zu:

    boost::thread thread2( &MyClass::DoStuff, &foo, 30  );
    Dies, denke ich, ist ein Kommentar von (oder zusätzlich zu) Josh ' s Antwort?

    InformationsquelleAutor dielor

Schreibe einen Kommentar