diff --git a/parallel_load.cpp b/parallel_load.cpp index 9fde112f..ff8f5a41 100644 --- a/parallel_load.cpp +++ b/parallel_load.cpp @@ -177,10 +177,11 @@ struct parallel_load finder successful_find{zipf1}, unsuccessful_find{zipf2}; - ready.arrive_and_wait(); + ready.count_down(); start.wait(); int n=i==0?(N+num_threads-1)/num_threads:N/num_threads; + n*=10; /* so that #updates = N */ for(int j=0;j(),N,theta,n)); - std::cout<(),N,theta,n)); - std::cout<(),N,theta,n)); - std::cout<