- File:
-
- 1 edited
-
tests/concurrent/pthread/bounded_buffer.cfa (modified) (2 diffs)
Legend:
- Unmodified
- Added
- Removed
-
tests/concurrent/pthread/bounded_buffer.cfa
rc63f470 r428adbc 63 63 64 64 void *producer( void *arg ) { 65 Buffer(int) &buf = *(Buffer(int)*)arg;66 const int NoOfItems = prng(*active_thread(), 40);65 Buffer(int) &buf = *(Buffer(int)*)arg; 66 const int NoOfItems = rand() % 40; 67 67 int item; 68 68 for ( int i = 1; i <= NoOfItems; i += 1 ) { // produce a bunch of items 69 item = prng(*active_thread(), 1, 101);// produce a random number69 item = rand() % 100 + 1; // produce a random number 70 70 //sout | "Producer:" | pthread_self() | " value:" | item; 71 71 insert( buf,item ); // insert element into queue … … 101 101 pthread_mutex_init(&consumer_cnt_lock, NULL); 102 102 // parallelism 103 s et_seed( 1003 );103 srandom( 1003 ); 104 104 105 105 processor p[5];
Note:
See TracChangeset
for help on using the changeset viewer.