LibNaegCommon/ThreadPooling.h at main · fractal-programming/LibNaegCommon · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
/*
  This file is part of the DSP-Crowd project
  https://www.dsp-crowd.com

  Author(s):
      - Johannes Natter, office@dsp-crowd.com

  File created on 01.02.2024

  Copyright (C) 2024, Johannes Natter

  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 of the License, 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, see <http://www.gnu.org/licenses/>.
*/

#ifndef THREAD_POOLING_H
#define THREAD_POOLING_H

#include <vector>
#include <list>
#include <mutex>

#include "Processing.h"
#include "Pipe.h"

typedef void (*FuncDriverPoolCreate)(Processing *pProc, uint16_t idProc);

struct PoolRequest
{
	Processing *pProc;
	int32_t idDriverDesired;
};

class ThreadPooling : public Processing
{

public:

	static ThreadPooling *create()
	{
		return new dNoThrow ThreadPooling;
	}

	void cntWorkerSet(uint16_t cnt);
	void driverCreateSet(FuncDriverPoolCreate pFctDriverCreate);

	static void procAdd(Processing *pProc, int32_t idDriver = -1);

protected:

	virtual ~ThreadPooling() {}

private:

	ThreadPooling();
	ThreadPooling(const ThreadPooling &) = delete;
	ThreadPooling &operator=(const ThreadPooling &) = delete;

	/*
	 * Naming of functions:  objectVerb()
	 * Example:              peerAdd()
	 */

	/* member functions */
	Success process();
	Success shutdown();
	void processInfo(char *pBuf, char *pBufEnd);

	void poolRequestsProcess();
	void procsDrive();
	size_t idDriverNextGet();
	size_t numProcessingGet();
	void procInternalAdd(Processing *pProc);

	/* member variables */
	uint32_t mStateSd;

	// Broker
	uint16_t mCntInternals;
	std::vector<ThreadPooling *> mVecInternals;
	FuncDriverPoolCreate mpFctDriverCreate;

	// Internal
	bool mIsInternal;
	size_t mNumProcessing;
	size_t mNumFinished;
	std::list<Processing *> mListProcsReq;
	std::list<Processing *> mListProcs;
	std::mutex mMtxBrokerInternal;

	/* static functions */

	/* static variables */
	static std::mutex mtxBroker;
	static bool brokerPresent;
	static Pipe<PoolRequest> ppPoolRequests;

	/* constants */

};

#endif