mirrors/z3
3
0
Fork 0
mirror of https://github.com/Z3Prover/z3 synced 2025-04-23 17:15:31 +00:00
Code Activity

add parameter for scenario from #4743

Browse source
This commit is contained in:
Nikolaj Bjorner 2020-10-30 01:14:34 -07:00
parent ceedd7e84d
commit f354671465
5 changed files with 21 additions and 18 deletions
Download patch file Download diff file Expand all files Collapse all files

19
src/util/scoped_timer.cpp
View file

@ -20,17 +20,19 @@ Revision History:
--*/
#include "util/scoped_timer.h"
#include "util/mutex.h"
#include "util/util.h"
#include "util/vector.h"
#include <chrono>
#include <climits>
#include <condition_variable>
#include <mutex>
#include <thread>
#include <vector>
#include <atomic>
struct state {
struct scoped_timer_state {
std::thread * m_thread { nullptr };
std::timed_mutex m_mutex;
event_handler * eh;
@ -39,11 +41,11 @@ struct state {
std::condition_variable_any cv;
};
static std::vector<state*> available_workers;
static std::vector<scoped_timer_state*> available_workers;
static std::mutex workers;
static atomic<unsigned> num_workers(0);
static std::atomic<unsigned> num_workers(0);
static void thread_func(state *s) {
static void thread_func(scoped_timer_state *s) {
workers.lock();
while (true) {
s->cv.wait(workers, [=]{ return s->work > 0; });
@ -71,16 +73,17 @@ static void thread_func(state *s) {
}
}
struct scoped_timer::imp {
private:
state *s;
scoped_timer_state *s;
public:
imp(unsigned ms, event_handler * eh) {
workers.lock();
if (available_workers.empty()) {
workers.unlock();
s = new state;
s = new scoped_timer_state;
++num_workers;
}
else {