CONSUMER_MAX
for (after = 0; after < CONSUMER_MAX; after++)
pthread_t pt[CONSUMER_MAX];
for (idx = 0; idx < CONSUMER_MAX; idx++) {