zzuummaa/multithread_experiments
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Small type improvements

Browse Source
This commit is contained in:
Фоменко Степан Владимирович
2020-07-17 11:00:22 +03:00
parent 87c903ff3d
commit bac4a8480e
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
experiments/block_choice.cpp
View File

@@ -152,7 +152,7 @@ void post_available_blocks(sm::block* calc_block, PIVector<sm::block*>& new_avai
sm::time_report algorithm_runnable(std::atomic_flag& block_pool_flag, sm::time_report algorithm_runnable(std::atomic_flag& block_pool_flag,
PIVector<sm::block*>& block_pool, PIVector<sm::block*>& block_pool,
std::atomic_int& waiting_threads_flags, std::atomic_uint& waiting_threads_flags,
unsigned i, unsigned thread_count) { unsigned i, unsigned thread_count) {
bool is_block_pool_empty; bool is_block_pool_empty;
bool is_block_pool_empty_old; bool is_block_pool_empty_old;
@@ -167,7 +167,7 @@ sm::time_report algorithm_runnable(std::atomic_flag& block_pool_flag,
new_available_blocks.clear(); new_available_blocks.clear();
if (is_block_pool_empty) { if (is_block_pool_empty) {
int waiting_threads_val; unsigned waiting_threads_val;
if (is_block_pool_empty_old) { if (is_block_pool_empty_old) {
waiting_threads_val = waiting_threads_flags.load(std::memory_order_acquire); waiting_threads_val = waiting_threads_flags.load(std::memory_order_acquire);
} else { } else {
@@ -202,7 +202,7 @@ sm::time_report algorithm_runnable(std::atomic_flag& block_pool_flag,
} }
std::vector<std::future<sm::time_report>> check_performance(const PIVector<sm::block*>& start_blocks, const unsigned thread_count) { std::vector<std::future<sm::time_report>> check_performance(const PIVector<sm::block*>& start_blocks, const unsigned thread_count) {
std::atomic_int waiting_threads_flags(0); std::atomic_uint waiting_threads_flags(0);
std::atomic_flag block_pool_flag = ATOMIC_FLAG_INIT; std::atomic_flag block_pool_flag = ATOMIC_FLAG_INIT;
PIVector<sm::block*> block_pool = start_blocks; PIVector<sm::block*> block_pool = start_blocks;