Rev 2028 | Rev 2050 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed
| Rev 2028 | Rev 2042 | ||
|---|---|---|---|
| Line 88... | Line 88... | ||
| 88 | 88 | ||
| 89 | printf("Creating %d consumers and %d producers...", consumers, producers); |
89 | printf("Creating %d consumers and %d producers...", consumers, producers); |
| 90 | 90 | ||
| 91 | for (j = 0; j < (CONSUMERS + PRODUCERS) / 2; j++) { |
91 | for (j = 0; j < (CONSUMERS + PRODUCERS) / 2; j++) { |
| 92 | for (k = 0; k < i; k++) { |
92 | for (k = 0; k < i; k++) { |
| 93 | thrd = thread_create(consumer, NULL, TASK, 0, "consumer"); |
93 | thrd = thread_create(consumer, NULL, TASK, 0, "consumer", false); |
| 94 | if (thrd) |
94 | if (thrd) |
| 95 | thread_ready(thrd); |
95 | thread_ready(thrd); |
| 96 | else |
96 | else |
| 97 | printf("could not create consumer %d\n", i); |
97 | printf("could not create consumer %d\n", i); |
| 98 | } |
98 | } |
| 99 | for (k = 0; k < (4 - i); k++) { |
99 | for (k = 0; k < (4 - i); k++) { |
| 100 | thrd = thread_create(producer, NULL, TASK, 0, "producer"); |
100 | thrd = thread_create(producer, NULL, TASK, 0, "producer", false); |
| 101 | if (thrd) |
101 | if (thrd) |
| 102 | thread_ready(thrd); |
102 | thread_ready(thrd); |
| 103 | else |
103 | else |
| 104 | printf("could not create producer %d\n", i); |
104 | printf("could not create producer %d\n", i); |
| 105 | } |
105 | } |