/* This file is part of Metaproxy.
- Copyright (C) 2005-2012 Index Data
+ Copyright (C) Index Data
Metaproxy is free software; you can redistribute it and/or modify it under
the terms of the GNU General Public License as published by the Free
class Worker;
public:
ThreadPoolSocketObserver(yazpp_1::ISocketObservable *obs,
- int no_threads);
+ unsigned min_threads, unsigned max_threads,
+ unsigned stack_size);
virtual ~ThreadPoolSocketObserver();
void put(IThreadPoolMsg *m);
void cleanup(IThreadPoolMsg *m, void *info);
IThreadPoolMsg *get();
void run(void *p);
+ void get_thread_info(int &tbusy, int &total);
private:
+ void add_worker(void);
void socketNotify(int event);
boost::scoped_ptr<Rep> m_p;