ADT
        ast-experimental
      
      
        
          | 
            Last change
 on this file since d8bdf13 was             b002261, checked in by Thierry Delisle <tdelisle@…>, 8 years ago           | 
        
        
          | 
             
Busy program now supports variable number of threads 
 
           | 
        
        
          
            
              - 
Property                 mode
 set to                 
100644
               
             
           | 
        
        
          | 
            File size:
            1.3 KB
           | 
        
      
      
| Line |   | 
|---|
| 1 | #include <stdbool.h>
 | 
|---|
| 2 | #include <stdio.h>
 | 
|---|
| 3 | #include <stdlib.h>
 | 
|---|
| 4 | #include <pthread.h>
 | 
|---|
| 5 | 
 | 
|---|
| 6 | struct S {
 | 
|---|
| 7 |         int i, j, k, l, m, n;
 | 
|---|
| 8 | };
 | 
|---|
| 9 | 
 | 
|---|
| 10 | void * CallingMalloc( void * arg __attribute__((unused)) ) {
 | 
|---|
| 11 |         for ( volatile int i = 0; i < 10000; i += 1 ) {
 | 
|---|
| 12 |                 volatile int      * ip  = (volatile int      *)malloc( sizeof(   int  ) *   1 );
 | 
|---|
| 13 |                 volatile int      * aip = (volatile int      *)malloc( sizeof(   int  ) * 100 );
 | 
|---|
| 14 |                 volatile struct S * sp  = (volatile struct S *)malloc( sizeof(struct S) * 200 );
 | 
|---|
| 15 | 
 | 
|---|
| 16 |                 sp->i = 0;
 | 
|---|
| 17 |                 sp->j = 1;
 | 
|---|
| 18 |                 sp->k = 2;
 | 
|---|
| 19 |                 sp->l = 3;
 | 
|---|
| 20 |                 sp->m = 4;
 | 
|---|
| 21 |                 sp->n = 5;
 | 
|---|
| 22 |                 for(int j = 0; j < 100; j++) {
 | 
|---|
| 23 |                         aip[j] = j;
 | 
|---|
| 24 |                 }
 | 
|---|
| 25 |                 *ip = i;
 | 
|---|
| 26 | 
 | 
|---|
| 27 |                 free( (void*)sp );
 | 
|---|
| 28 |                 free( (void*)aip );
 | 
|---|
| 29 |                 free( (void*)ip );
 | 
|---|
| 30 |         }
 | 
|---|
| 31 |         return NULL;
 | 
|---|
| 32 | }
 | 
|---|
| 33 | 
 | 
|---|
| 34 | int main(int argc, const char * const argv[]) {
 | 
|---|
| 35 |         char * endptr;
 | 
|---|
| 36 |         int nThreads = 15;
 | 
|---|
| 37 |         switch(argc) {
 | 
|---|
| 38 |         case 1:
 | 
|---|
| 39 |                 break;
 | 
|---|
| 40 |         case 2:
 | 
|---|
| 41 |                 nThreads = strtol(argv[1], &endptr, 10);
 | 
|---|
| 42 |                 if( *endptr != 0 || nThreads <= 0 ) {
 | 
|---|
| 43 |                         fprintf(stderr, "Invalid number of threads %s\n", argv[1]);
 | 
|---|
| 44 |                         return 1;
 | 
|---|
| 45 |                 }
 | 
|---|
| 46 |                 break;
 | 
|---|
| 47 |         default:
 | 
|---|
| 48 |                 fprintf(stderr, "Usage: %s [no of threads]\n", argv[0]);
 | 
|---|
| 49 |                 return 1;
 | 
|---|
| 50 |         }
 | 
|---|
| 51 |         printf("Running %d threads\n", nThreads);
 | 
|---|
| 52 |         while(true) {
 | 
|---|
| 53 |                 pthread_t t[nThreads];
 | 
|---|
| 54 |                 for(int i = 0; i < nThreads; i++) {
 | 
|---|
| 55 |                         pthread_create( &t[i], NULL, CallingMalloc, NULL );
 | 
|---|
| 56 |                 }
 | 
|---|
| 57 | 
 | 
|---|
| 58 |                 for(int i = 0; i < nThreads; i++) {
 | 
|---|
| 59 |                         pthread_join( t[i], NULL );
 | 
|---|
| 60 |                 }
 | 
|---|
| 61 |         }
 | 
|---|
| 62 |         return 0;
 | 
|---|
| 63 | }
 | 
|---|
       
      
  Note:
 See   
TracBrowser
 for help on using the repository browser.