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 26template <class ITEM> class Vector; 27 28class DbeQueue 29{ 30public: 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 40class DbeThreadPool 41{ 42public: 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; 52private: 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 62