X-Git-Url: http://plrg.eecs.uci.edu/git/?p=model-checker-benchmarks.git;a=blobdiff_plain;f=mpmc-queue%2Fmpmc-queue.cc;h=17713cbfb5f3f162a91c2117e7907b11abe21681;hp=146f11ec482a745c26e8125bc78c42cfb8616212;hb=fca16811b01b581abd2a12df879558cdf32663e4;hpb=650879eaa7fc800f453f65c717ccd8c30aa1089b

diff --git a/mpmc-queue/mpmc-queue.cc b/mpmc-queue/mpmc-queue.cc
index 146f11e..17713cb 100644
--- a/mpmc-queue/mpmc-queue.cc
+++ b/mpmc-queue/mpmc-queue.cc
@@ -15,9 +15,11 @@ void threadA(struct mpmc_boundq_1_alt<int32_t, sizeof(int32_t)> *queue)
 
 void threadB(struct mpmc_boundq_1_alt<int32_t, sizeof(int32_t)> *queue)
 {
-	int32_t *bin = queue->read_fetch();
-	printf("Read: %d\n", load_32(bin));
-	queue->read_consume();
+	int32_t *bin;
+	while (bin = queue->read_fetch()) {
+		printf("Read: %d\n", load_32(bin));
+		queue->read_consume();
+	}
 }
 
 int user_main(int argc, char **argv)