abstractthreadedserver.h

#ifndef ABSTRACTTHREADEDSERVER_H
#define ABSTRACTTHREADEDSERVER_H
 
#include "abstractserverconnector.h"
#include "threadpool.h"
#include <memory>
#include <thread>
 
namespace jsonrpc {
class AbstractThreadedServer : public AbstractServerConnector {
public:
  AbstractThreadedServer(size_t threads);
  virtual ~AbstractThreadedServer();
 
  virtual bool StartListening();
  virtual bool StopListening();
 
protected:
  virtual bool InitializeListener() = 0;
 
  virtual int CheckForConnection() = 0;
 
  virtual void HandleConnection(int connection) = 0;
 
private:
  bool running;
  std::unique_ptr<std::thread> listenerThread;
  ThreadPool threadPool;
  size_t threads;
 
  void ListenLoop();
};
}
 
#endif // ABSTRACTTHREADEDSERVER_H