projects
/
model-checker-benchmarks.git
/ commitdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
| commitdiff |
tree
raw
|
patch
|
inline
| side by side (parent:
a2eed12
)
mpmc-queue: run more producer/consumer threads
author
Brian Norris
<banorris@uci.edu>
Thu, 1 Nov 2012 19:22:56 +0000
(12:22 -0700)
committer
Brian Norris
<banorris@uci.edu>
Thu, 1 Nov 2012 19:22:56 +0000
(12:22 -0700)
mpmc-queue/mpmc-queue.cc
patch
|
blob
|
history
diff --git
a/mpmc-queue/mpmc-queue.cc
b/mpmc-queue/mpmc-queue.cc
index 17713cbfb5f3f162a91c2117e7907b11abe21681..741811aaf357578bc0d0056d4ce4272f66881dc8 100644
(file)
--- a/
mpmc-queue/mpmc-queue.cc
+++ b/
mpmc-queue/mpmc-queue.cc
@@
-25,7
+25,7
@@
void threadB(struct mpmc_boundq_1_alt<int32_t, sizeof(int32_t)> *queue)
int user_main(int argc, char **argv)
{
struct mpmc_boundq_1_alt<int32_t, sizeof(int32_t)> queue;
int user_main(int argc, char **argv)
{
struct mpmc_boundq_1_alt<int32_t, sizeof(int32_t)> queue;
- thrd_t A
, B
;
+ thrd_t A
1, A2, B1, B2
;
int32_t *bin = queue.write_prepare();
store_32(bin, 17);
int32_t *bin = queue.write_prepare();
store_32(bin, 17);
@@
-33,10
+33,14
@@
int user_main(int argc, char **argv)
printf("Start threads\n");
printf("Start threads\n");
- thrd_create(&A, (thrd_start_t)&threadA, &queue);
- thrd_create(&B, (thrd_start_t)&threadB, &queue);
- thrd_join(A);
- thrd_join(B);
+ thrd_create(&A1, (thrd_start_t)&threadA, &queue);
+ thrd_create(&A2, (thrd_start_t)&threadA, &queue);
+ thrd_create(&B1, (thrd_start_t)&threadB, &queue);
+ thrd_create(&B2, (thrd_start_t)&threadB, &queue);
+ thrd_join(A1);
+ thrd_join(A2);
+ thrd_join(B1);
+ thrd_join(B2);
printf("Threads complete\n");
printf("Threads complete\n");