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