3
0
Fork 0
mirror of https://github.com/Z3Prover/z3 synced 2025-04-07 01:54:08 +00:00
z3/src/sat/sat_parallel.h
Nikolaj Bjorner e83e9b02df increment version number to 4.8.4
Signed-off-by: Nikolaj Bjorner <nbjorner@microsoft.com>
2018-11-19 15:17:55 -08:00

115 lines
3 KiB
C++

/*++
Copyright (c) 2017 Microsoft Corporation
Module Name:
sat_parallel.h
Abstract:
Utilities for parallel SAT solving.
Author:
Nikolaj Bjorner (nbjorner) 2017-1-29.
Revision History:
--*/
#ifndef SAT_PARALLEL_H_
#define SAT_PARALLEL_H_
#include "sat/sat_types.h"
#include "util/hashtable.h"
#include "util/map.h"
#include "util/rlimit.h"
namespace sat {
class local_search;
class parallel {
// shared pool of learned clauses.
class vector_pool {
unsigned_vector m_vectors;
unsigned m_size;
unsigned m_tail;
unsigned_vector m_heads;
svector<bool> m_at_end;
void next(unsigned& index);
unsigned get_owner(unsigned index) const { return m_vectors[index]; }
unsigned get_length(unsigned index) const { return m_vectors[index+1]; }
unsigned const* get_ptr(unsigned index) const { return m_vectors.c_ptr() + index + 2; }
public:
vector_pool() {}
void reserve(unsigned num_owners, unsigned sz);
void begin_add_vector(unsigned owner, unsigned n);
void end_add_vector();
void add_vector_elem(unsigned e);
bool get_vector(unsigned owner, unsigned& n, unsigned const*& ptr);
};
bool enable_add(clause const& c) const;
void _get_clauses(solver& s);
void _get_phase(solver& s);
void _set_phase(solver& s);
typedef hashtable<unsigned, u_hash, u_eq> index_set;
literal_vector m_units;
index_set m_unit_set;
literal_vector m_lits;
vector_pool m_pool;
// for exchange with local search:
svector<lbool> m_phase;
unsigned m_num_clauses;
scoped_ptr<solver> m_solver_copy;
bool m_consumer_ready;
scoped_limits m_scoped_rlimit;
vector<reslimit> m_limits;
ptr_vector<solver> m_solvers;
public:
parallel(solver& s);
~parallel();
void init_solvers(solver& s, unsigned num_extra_solvers);
void push_child(reslimit& rl);
// reserve space
void reserve(unsigned num_owners, unsigned sz) { m_pool.reserve(num_owners, sz); }
solver& get_solver(unsigned i) { return *m_solvers[i]; }
void cancel_solver(unsigned i) { m_limits[i].cancel(); }
// exchange unit literals
void exchange(solver& s, literal_vector const& in, unsigned& limit, literal_vector& out);
// add clause to shared clause pool
void share_clause(solver& s, clause const& c);
void share_clause(solver& s, literal l1, literal l2);
// receive clauses from shared clause pool
void get_clauses(solver& s);
// exchange phase of variables.
void set_phase(solver& s);
void get_phase(solver& s);
bool get_phase(local_search& s);
bool copy_solver(solver& s);
};
};
#endif