1  /* Copyright (C) 2021-2023 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