mirror of
https://github.com/data61/MP-SPDZ.git
synced 2026-01-10 05:57:57 -05:00
34 lines
798 B
C++
34 lines
798 B
C++
/*
|
|
* ThreadQueues.h
|
|
*
|
|
*/
|
|
|
|
#ifndef PROCESSOR_THREADQUEUES_H_
|
|
#define PROCESSOR_THREADQUEUES_H_
|
|
|
|
#include "Tools/WaitQueue.h"
|
|
#include "ThreadJob.h"
|
|
#include "ThreadQueue.h"
|
|
|
|
class ThreadQueues :
|
|
public vector<ThreadQueue*>
|
|
{
|
|
vector<int> available;
|
|
|
|
public:
|
|
int find_available();
|
|
int get_n_per_thread(int n_items, int granularity = 1);
|
|
// expects that the last slice is done by the caller
|
|
int distribute(ThreadJob job, int n_items, int base = 0,
|
|
int granularity = 1);
|
|
int distribute_no_setup(ThreadJob job, int n_items, int base = 0,
|
|
int granularity = 1, const vector<void*>* supplies = 0);
|
|
void wrap_up(ThreadJob job);
|
|
|
|
TimerWithComm sum(const string& phase);
|
|
|
|
void print_breakdown();
|
|
};
|
|
|
|
#endif /* PROCESSOR_THREADQUEUES_H_ */
|