Category

Development Platform
Home > SourceCode/Document > OS Develop > View Code
TEST5.C
Package: ertos.rar　[view]
Upload User: sunrenlu
Upload Date: 2022-06-13
Package Size: 1419k
Code Size: 1k
Category:

OS Develop

Development Platform:

DOS

TEST5.C：Code Content
  1. /**************************************************************************/
  2. /* test5 - shows byte queue tools                                         */
  3. /**************************************************************************/
  5. #include "rtos.h"
  6. #include <stdio.h>
  7. #include <stdlib.h>
  9. void *peer = NULL;
  10. bq_str *bq = NULL;  /* byte queue */
  12. void switcher1(DWORD arg)
  13. {
  14.     int x;
  16. #if defined(__TURBOC__)||defined(__BORLANDC__)
  17.     randomize();
  18. #else
  19.     srand( time( 0 ));
  20. #endif
  22.     do {
  23.         rt_yield();
  24.         x = rand();
  25.         if ( x > 25000 ) {
  26.             x = ( x & 255 );
  27.             cprintf( " sending %u ", x );
  28.             bq_writebyte( bq, x );
  29.             bq_writebyte( bq, x );
  30.             bq_writebyte( bq, x );
  31.             bq_writebyte( bq, x );
  32.             bq_writebyte( bq, x );
  33.         }
  34.     } while ( 1 );
  35. }
  36. void switcher2(DWORD arg)
  37. {
  38.     int x, cnt, i;
  39.     do {
  40.         rt_yield();
  41.         cnt = bq_readcount( bq );
  42.         if ( cnt == 0 ) cprintf(".");
  43.         else for ( i = 0 ; i < cnt ; ++i ) {
  44.             if ( bq_readbyte( bq , &x ))
  45.                 cprintf(" read %u rn", x );
  46.         }
  47.     } while ( 1 );
  48. }
  50. main()
  51. {
  52.     kdebug = 1;
  53.     rt_init(100);
  54.     bq = bq_alloc( 100 );
  55.     cputs("starting...rn");
  56.     peer = rt_newthread( switcher2, 2,4096, 0, "worker 2" );
  57.     rt_newthread( switcher1, 1,4096, 0, "worker 1" );
  58.     rt_sleep( 10000 );
  59. }