diff options
Diffstat (limited to 'test/core/gpr/arena_test.cc')
-rw-r--r-- | test/core/gpr/arena_test.cc | 18 |
1 files changed, 11 insertions, 7 deletions
diff --git a/test/core/gpr/arena_test.cc b/test/core/gpr/arena_test.cc index 1cfaefa686..717052eacd 100644 --- a/test/core/gpr/arena_test.cc +++ b/test/core/gpr/arena_test.cc @@ -18,15 +18,17 @@ #include "src/core/lib/gpr/arena.h" +#include <new> +#include <inttypes.h> +#include <string.h> + #include <grpc/support/alloc.h> #include <grpc/support/log.h> #include <grpc/support/string_util.h> #include <grpc/support/sync.h> -#include <inttypes.h> -#include <string.h> #include "src/core/lib/gpr/string.h" -#include "src/core/lib/gpr/thd.h" +#include "src/core/lib/gprpp/thd.h" #include "src/core/lib/gpr/useful.h" #include "test/core/util/test_config.h" @@ -97,16 +99,18 @@ static void concurrent_test(void) { gpr_event_init(&args.ev_start); args.arena = gpr_arena_create(1024); - gpr_thd_id thds[CONCURRENT_TEST_THREADS]; + grpc_core::Thread thds[CONCURRENT_TEST_THREADS]; for (int i = 0; i < CONCURRENT_TEST_THREADS; i++) { - gpr_thd_new(&thds[i], "grpc_concurrent_test", concurrent_test_body, &args); + new (&thds[i]) grpc_core::Thread("grpc_concurrent_test", + concurrent_test_body, &args); + thds[i].Start(); } gpr_event_set(&args.ev_start, (void*)1); - for (int i = 0; i < CONCURRENT_TEST_THREADS; i++) { - gpr_thd_join(thds[i]); + for (auto& th : thds) { + th.Join(); } gpr_arena_destroy(args.arena); |