gprofng/src/DbeThread.h

   1 /* Copyright (C) 2021 Free Software Foundation, Inc.
   2    Contributed by Oracle.
   3
   4    This file is part of GNU Binutils.
   5
   6    This program is free software; you can redistribute it and/or modify
   7    it under the terms of the GNU General Public License as published by
   8    the Free Software Foundation; either version 3, or (at your option)
   9    any later version.
  10
  11    This program is distributed in the hope that it will be useful,
  12    but WITHOUT ANY WARRANTY; without even the implied warranty of
  13    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  14    GNU General Public License for more details.
  15
  16    You should have received a copy of the GNU General Public License
  17    along with this program; if not, write to the Free Software
  18    Foundation, 51 Franklin Street - Fifth Floor, Boston,
  19    MA 02110-1301, USA.  */
  20
  21 #ifndef _DBETHREAD_H
  22 #define _DBETHREAD_H
  23 #include <pthread.h>
  24 #include "DbeLinkList.h"
  25
  26 template <class ITEM> class Vector;
  27
  28 class DbeQueue
  29 {
  30 public:
  31   DbeQueue (int (*_func)(void *arg), void *_arg);
  32   ~DbeQueue ();
  33
  34   int (*func) (void *arg);
  35   void *arg;
  36   int id;
  37   DbeQueue *next;
  38 };
  39
  40 class DbeThreadPool
  41 {
  42 public:
  43   DbeThreadPool (int _max_threads);
  44   ~DbeThreadPool ();
  45   DbeQueue *get_queue ();
  46   void put_queue (DbeQueue *q);
  47   void wait_queues ();
  48
  49   pthread_mutex_t p_mutex;
  50   pthread_cond_t p_cond_var;
  51   volatile bool no_new_queues;
  52 private:
  53   Vector<pthread_t> *threads;
  54   int max_threads;
  55   DbeQueue *volatile queue;
  56   DbeQueue *volatile last_queue;
  57   volatile int queues_cnt;
  58   volatile int total_queues;
  59 };
  60
  61 #endif