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