@@ -311,7 +311,7 @@ struct Response {
311
311
312
312
class Stream {
313
313
public:
314
- virtual ~Stream () {}
314
+ virtual ~Stream () = default ;
315
315
virtual int read (char *ptr, size_t size) = 0;
316
316
virtual int write (const char *ptr, size_t size1) = 0;
317
317
virtual int write (const char *ptr) = 0;
@@ -326,7 +326,7 @@ class SocketStream : public Stream {
326
326
public:
327
327
SocketStream (socket_t sock, time_t read_timeout_sec,
328
328
time_t read_timeout_usec);
329
- virtual ~SocketStream ();
329
+ ~SocketStream () override ;
330
330
331
331
int read (char *ptr, size_t size) override ;
332
332
int write (const char *ptr, size_t size) override ;
@@ -342,8 +342,8 @@ class SocketStream : public Stream {
342
342
343
343
class BufferStream : public Stream {
344
344
public:
345
- BufferStream () {}
346
- virtual ~BufferStream () {}
345
+ BufferStream () = default ;
346
+ ~BufferStream () override = default ;
347
347
348
348
int read (char *ptr, size_t size) override ;
349
349
int write (const char *ptr, size_t size) override ;
@@ -359,16 +359,16 @@ class BufferStream : public Stream {
359
359
360
360
class TaskQueue {
361
361
public:
362
- TaskQueue () {}
363
- virtual ~TaskQueue () {}
362
+ TaskQueue () = default ;
363
+ virtual ~TaskQueue () = default ;
364
364
virtual void enqueue (std::function<void ()> fn) = 0;
365
365
virtual void shutdown () = 0;
366
366
};
367
367
368
368
#if CPPHTTPLIB_THREAD_POOL_COUNT > 0
369
369
class ThreadPool : public TaskQueue {
370
370
public:
371
- ThreadPool (size_t n) : shutdown_(false ) {
371
+ explicit ThreadPool (size_t n) : shutdown_(false ) {
372
372
while (n) {
373
373
auto t = std::make_shared<std::thread>(worker (*this ));
374
374
threads_.push_back (t);
@@ -377,15 +377,15 @@ class ThreadPool : public TaskQueue {
377
377
}
378
378
379
379
ThreadPool (const ThreadPool &) = delete ;
380
- virtual ~ThreadPool () {}
380
+ ~ThreadPool () override = default ;
381
381
382
- virtual void enqueue (std::function<void ()> fn) override {
382
+ void enqueue (std::function<void ()> fn) override {
383
383
std::unique_lock<std::mutex> lock (mutex_);
384
384
jobs_.push_back (fn);
385
385
cond_.notify_one ();
386
386
}
387
387
388
- virtual void shutdown () override {
388
+ void shutdown () override {
389
389
// Stop all worker threads...
390
390
{
391
391
std::unique_lock<std::mutex> lock (mutex_);
@@ -402,7 +402,7 @@ class ThreadPool : public TaskQueue {
402
402
403
403
private:
404
404
struct worker {
405
- worker (ThreadPool &pool) : pool_(pool) {}
405
+ explicit worker (ThreadPool &pool) : pool_(pool) {}
406
406
407
407
void operator ()() {
408
408
for (;;) {
0 commit comments