1 files changed, 61 insertions, 0 deletions
diff --git a/gprofng/src/DbeThread.h b/gprofng/src/DbeThread.h
new file mode 100644
index 00000000000..8ee148b4ed7
--- /dev/null
+++ b/gprofng/src/DbeThread.h
@@ -0,0 +1,61 @@
+/* Copyright (C) 2021 Free Software Foundation, Inc.
+   Contributed by Oracle.
+
+   This file is part of GNU Binutils.
+
+   This program is free software; you can redistribute it and/or modify
+   it under the terms of the GNU General Public License as published by
+   the Free Software Foundation; either version 3, or (at your option)
+   any later version.
+
+   This program is distributed in the hope that it will be useful,
+   but WITHOUT ANY WARRANTY; without even the implied warranty of
+   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+   GNU General Public License for more details.
+
+   You should have received a copy of the GNU General Public License
+   along with this program; if not, write to the Free Software
+   Foundation, 51 Franklin Street - Fifth Floor, Boston,
+   MA 02110-1301, USA.  */
+
+#ifndef _DBETHREAD_H
+#define _DBETHREAD_H
+#include <pthread.h>
+#include "DbeLinkList.h"
+
+template <class ITEM> class Vector;
+
+class DbeQueue
+{
+public:
+  DbeQueue (int (*_func)(void *arg), void *_arg);
+  ~DbeQueue ();
+
+  int (*func) (void *arg);
+  void *arg;
+  int id;
+  DbeQueue *next;
+};
+
+class DbeThreadPool
+{
+public:
+  DbeThreadPool (int _max_threads);
+  ~DbeThreadPool ();
+  DbeQueue *get_queue ();
+  void put_queue (DbeQueue *q);
+  void wait_queues ();
+
+  pthread_mutex_t p_mutex;
+  pthread_cond_t p_cond_var;
+  volatile bool no_new_queues;
+private:
+  Vector<pthread_t> *threads;
+  int max_threads;
+  DbeQueue *volatile queue;
+  DbeQueue *volatile last_queue;
+  volatile int queues_cnt;
+  volatile int total_queues;
+};
+
+#endif