Make the s variable of ascs::list volatile.

examples/echo_client/echo_client.cpp

@@ -241,11 +241,11 @@ void send_msg_one_by_one(echo_client& client, size_t msg_num, size_t msg_len, ch
 			printf("\r%u%%", percent);
 			fflush(stdout);
 		}
-	} while (100 != percent);
+	} while (percent < 100);
 	begin_time.stop();
 
-	printf("\r100%%\ntime spent statistics: %f seconds.\n", begin_time.elapsed());
-	printf("speed: %.0f(*2)kB/s.\n", total_msg_bytes / begin_time.elapsed() / 1024);
+	printf("\ntime spent statistics: %f seconds.\n", begin_time.elapsed());
+	printf("speed: %f(*2) MBps.\n", total_msg_bytes / begin_time.elapsed() / 1024 / 1024);
 }
 
 void send_msg_randomly(echo_client& client, size_t msg_num, size_t msg_len, char msg_fill)
@@ -275,14 +275,14 @@ void send_msg_randomly(echo_client& client, size_t msg_num, size_t msg_len, char
 		}
 	}
 
-	while(client.get_recv_bytes() != total_msg_bytes)
+	while(client.get_recv_bytes() < total_msg_bytes)
 		std::this_thread::sleep_for(std::chrono::milliseconds(50));
 
 	begin_time.stop();
 	delete[] buff;
 
-	printf("\r100%%\ntime spent statistics: %f seconds.\n", begin_time.elapsed());
-	printf("speed: %.0f(*2)kB/s.\n", total_msg_bytes / begin_time.elapsed() / 1024);
+	printf("\ntime spent statistics: %f seconds.\n", begin_time.elapsed());
+	printf("speed: %f(*2) MBps.\n", total_msg_bytes / begin_time.elapsed() / 1024 / 1024);
 }
 
 //use up to a specific worker threads to send messages concurrently
@@ -346,12 +346,12 @@ void send_msg_concurrently(echo_client& client, size_t send_thread_num, size_t m
 			printf("\r%u%%", percent);
 			fflush(stdout);
 		}
-	} while (100 != percent);
+	} while (percent < 100);
 	do_something_to_all(threads, [](auto& t) {t.join();});
 	begin_time.stop();
 
-	printf("\r100%%\ntime spent statistics: %f seconds.\n", begin_time.elapsed());
-	printf("speed: %.0f(*2)kB/s.\n", total_msg_bytes / begin_time.elapsed() / 1024);
+	printf("\ntime spent statistics: %f seconds.\n", begin_time.elapsed());
+	printf("speed: %f(*2) MBps.\n", total_msg_bytes / begin_time.elapsed() / 1024 / 1024);
 }
 
 int main(int argc, const char* argv[])
@@ -403,13 +403,9 @@ int main(int argc, const char* argv[])
 	auto thread_num = 1;
 	if (argc > 1)
 		thread_num = std::min(16, std::max(thread_num, atoi(argv[1])));
-#ifdef ASCS_CLEAR_OBJECT_INTERVAL
-	if (1 == thread_num)
-		++thread_num;
 	//add one thread will seriously impact IO throughput when doing performance benchmark, this is because the business logic is very simple (send original messages back,
 	//or just add up total message size), under this scenario, just one service thread without receiving buffer will obtain the best IO throughput.
 	//the server has such behavior too.
-#endif
 
 	sp.start_service(thread_num);
 	while(sp.is_running())
@@ -500,7 +496,7 @@ int main(int argc, const char* argv[])
 			puts("performance test begin, this application will have no response during the test!");
 			for (int i = 0; i < repeat_times; ++i)
 			{
-				printf("thie is the %d / %d test.\n", i + 1, repeat_times);
+				printf("this is the %d / %d test.\n", i + 1, repeat_times);
 				client.clear_status();
 #ifdef ASCS_WANT_MSG_SEND_NOTIFY
 				if (0 == model)

examples/file_client/file_client.h

@@ -178,7 +178,7 @@ public:
 	void stop(const std::string& file_name)
 	{
 		stop_timer(UPDATE_PROGRESS);
-		printf("\r100%%\ntransfer %s end, speed: %.0f kB/s.\n", file_name.data(), file_size / begin_time.elapsed() / 1024);
+		printf("\ntransfer %s end, speed: %f MBps.\n", file_name.data(), file_size / begin_time.elapsed() / 1024 / 1024);
 	}
 
 	fl_type get_total_rest_size()

examples/pingpong_client/pingpong_client.cpp

@@ -119,7 +119,7 @@ public:
 	statistic get_statistic()
 	{
 		statistic stat;
-		do_something_to_all([&stat](const auto& item) {stat += item->get_statistic(); });
+		do_something_to_all([&stat](const auto& item) {stat += item->get_statistic();});
 
 		return stat;
 	}
@@ -154,13 +154,9 @@ int main(int argc, const char* argv[])
 	auto thread_num = 1;
 	if (argc > 1)
 		thread_num = std::min(16, std::max(thread_num, atoi(argv[1])));
-#ifdef ASCS_CLEAR_OBJECT_INTERVAL
-	if (1 == thread_num)
-		++thread_num;
 	//add one thread will seriously impact IO throughput when doing performance benchmark, this is because the business logic is very simple (send original messages back,
 	//or just add up total message size), under this scenario, just one service thread without receiving buffer will obtain the best IO throughput.
 	//the server has such behavior too.
-#endif
 
 	for (size_t i = 0; i < link_num; ++i)
 		client.add_client(port, ip);
@@ -203,7 +199,7 @@ int main(int argc, const char* argv[])
 				std::this_thread::sleep_for(std::chrono::milliseconds(50));
 
 			uint64_t total_msg_bytes = link_num; total_msg_bytes *= msg_len; total_msg_bytes *= msg_num;
-			printf("\r100%%\ntime spent statistics: %f seconds.\n", begin_time.elapsed());
+			printf("time spent statistics: %f seconds.\n", begin_time.elapsed());
 			printf("speed: %f(*2) MBps.\n", total_msg_bytes / begin_time.elapsed() / 1024 / 1024);
 
 			delete[] init_msg;

include/ascs/container.h

@@ -116,7 +116,7 @@ public:
 	}
 
 private:
-	size_type s;
+	volatile size_type s;
 	_Mybase impl;
 };
 #endif