From 21497d65a579ff441be9530a6b8784ad6b940e2d Mon Sep 17 00:00:00 2001 From: taymindis Date: Sat, 15 Sep 2018 17:15:59 +0800 Subject: [PATCH] Update Full feature Test Code --- example.c | 151 ++++++++++++++++++++++++++++++++++++++++++++++++------ 1 file changed, 135 insertions(+), 16 deletions(-) diff --git a/example.c b/example.c index 783b6ce..93c0195 100644 --- a/example.c +++ b/example.c @@ -9,6 +9,8 @@ #include "lfqueue.h" +typedef void (*test_function)(pthread_t*); + void one_enq_and_multi_deq(pthread_t *threads); void one_deq_and_multi_enq(pthread_t *threads); void multi_enq_deq(pthread_t *threads); @@ -17,13 +19,79 @@ void* worker_s(void *); void* worker_c(void *); void* worker_single_c(void *); +/**Testing must**/ +void one_enq_and_multi_deq_must(pthread_t *threads); +void one_deq_must_and_multi_enq(pthread_t *threads); +void multi_enq_deq_must(pthread_t *threads); +void* worker_sc_must(void *); +void* worker_s_must(void *); +void* worker_c_must(void *); +void* worker_single_c_must(void *); + +void running_test(test_function testfn); + struct timeval tv1, tv2; #define total_put 50000 -int nthreads = 4; //sysconf(_SC_NPROCESSORS_ONLN); // Linux +#define total_running_loop 50 +int nthreads = 4; int one_thread = 1; int nthreads_exited = 0; lfqueue_t *myq; + + +void* worker_c_must(void *arg) { + int i = 0; + int *int_data; + int total_loop = total_put * (*(int*)arg); + while (i++ < total_loop) { + /*Dequeue*/ + int_data = lfqueue_deq_must(myq); + // printf("%d\n", *int_data); + + free(int_data); + } + __sync_add_and_fetch(&nthreads_exited, 1); + return 0; +} + +void* worker_single_c_must(void *arg) { + int i = 0; + int *int_data; + int total_loop = total_put * (*(int*)arg); + while (i++ < total_loop) { + /*Dequeue*/ + int_data = lfqueue_single_deq_must(myq); + // printf("%d\n", *int_data); + + free(int_data); + } + __sync_add_and_fetch(&nthreads_exited, 1); + return 0; +} + +void* worker_sc_must(void *arg) +{ + int i = 0; + int *int_data; + while (i < total_put) { + int_data = (int*)malloc(sizeof(int)); + assert(int_data != NULL); + *int_data = i++; + /*Enqueue*/ + while (lfqueue_enq(myq, int_data)) { + printf("ENQ FULL?\n"); + } + + /*Dequeue*/ + int_data = lfqueue_deq_must(myq); + // printf("%d\n", *int_data); + free(int_data); + } + __sync_add_and_fetch(&nthreads_exited, 1); + return 0; +} + void* worker_c(void *arg) { int i = 0; int *int_data; @@ -31,7 +99,7 @@ void* worker_c(void *arg) { while (i++ < total_loop) { /*Dequeue*/ while ((int_data = lfqueue_deq(myq)) == NULL) { - + lfqueue_sleep(1); } // printf("%d\n", *int_data); @@ -48,7 +116,7 @@ void* worker_single_c(void *arg) { while (i++ < total_loop) { /*Dequeue*/ while ((int_data = lfqueue_single_deq(myq)) == NULL) { - + lfqueue_sleep(1); } // printf("%d\n", *int_data); @@ -93,7 +161,7 @@ void* worker_sc(void *arg) /*Dequeue*/ while ((int_data = lfqueue_deq(myq)) == NULL) { - // printf("DEQ EMPTY? %zu\n", lfqueue_size(myq)); + lfqueue_sleep(1); } // printf("%d\n", *int_data); free(int_data); @@ -126,6 +194,7 @@ void multi_enq_deq(pthread_t *threads) { join_threads; // detach_thread_and_loop; } + void one_deq_and_multi_enq(pthread_t *threads) { printf("-----------%s---------------\n", "one_deq_and_multi_enq"); int i; @@ -152,29 +221,62 @@ void one_enq_and_multi_deq(pthread_t *threads) { #pragma GCC diagnostic pop } -int ri = 10; -int main(void) -{ - int n; - myq = malloc(sizeof (lfqueue_t)); - if (lfqueue_init(myq) == -1) - return -1; - for (n = 0; n < 300; n++) { +void one_deq_must_and_multi_enq(pthread_t *threads) { + printf("-----------%s---------------\n", "one_deq_must_and_multi_enq"); + int i; + for (i = 0; i < nthreads; i++) + pthread_create(threads + i, NULL, worker_s, &one_thread); + + worker_single_c_must(&nthreads); + + join_threads; + // detach_thread_and_loop; +} + +void one_enq_and_multi_deq_must(pthread_t *threads) { + printf("-----------%s---------------\n", "one_enq_and_multi_deq_must"); + int i; + for (i = 0; i < nthreads; i++) + pthread_create(threads + i, NULL, worker_c_must, &one_thread); + + worker_s(&nthreads); + +#pragma GCC diagnostic push +#pragma GCC diagnostic ignored "-Wimplicit-function-declaration" + detach_thread_and_loop; +#pragma GCC diagnostic pop + +} + +void multi_enq_deq_must(pthread_t *threads) { + printf("-----------%s---------------\n", "multi_enq_deq_must"); + int i; + for (i = 0; i < nthreads; i++) { + pthread_create(threads + i, NULL, worker_sc_must, NULL); + } + + join_threads; + // detach_thread_and_loop; +} + +void running_test(test_function testfn) { + int n; + for (n = 0; n < total_running_loop; n++) { printf("Current running at =%d, ", n); nthreads_exited = 0; - /* Spawn threads. */ pthread_t threads[nthreads]; printf("Using %d thread%s.\n", nthreads, nthreads == 1 ? "" : "s"); printf("Total requests %d \n", total_put); gettimeofday(&tv1, NULL); - //one_enq_and_multi_deq(threads); + testfn(threads); + // one_enq_and_multi_deq(threads); //one_deq_and_multi_enq(threads); - multi_enq_deq(threads); + // multi_enq_deq(threads); // worker_s(&ri); // worker_c(&ri); @@ -183,14 +285,31 @@ int main(void) (double) (tv2.tv_usec - tv1.tv_usec) / 1000000 + (double) (tv2.tv_sec - tv1.tv_sec)); - //getchar(); lfqueue_sleep(10); assert ( 0 == lfqueue_size(myq) && "Error, all queue should be consumed but not"); } +} + +int main(void) { + myq = malloc(sizeof (lfqueue_t)); + if (lfqueue_init(myq) == -1) + return -1; + + running_test(one_enq_and_multi_deq); + running_test(one_enq_and_multi_deq_must); + + running_test(one_deq_and_multi_enq); + running_test(one_deq_must_and_multi_enq); + + running_test(multi_enq_deq); + running_test(multi_enq_deq_must); + + lfqueue_destroy(myq); // sleep(3); free(myq); + printf("Test Pass!\n"); return 0; }