TEST.C
上传用户:sunrenlu
上传日期:2022-06-13
资源大小:1419k
文件大小:2k
源码类别:

操作系统开发

开发平台:

DOS

  1. #include <stdio.h>
  2. #include <stdlib.h>
  3. #include <setjmp.h>
  4. #include <dos.h>
  5. #include <mem.h>
  6. #include <time.h>
  7. #include <rtos.h>
  8. #include <conio.h>
  9. #if defined(__TURBOC__) || defined(__BORLANDC__)
  10. #define STACKLEN 2048
  11. #else
  12. #define STACKLEN 4096
  13. #endif
  14. /*********************************************************/
  15. void test(DWORD arg)
  16. {
  17.     int i = 0, j;
  18.     kwindow( 1, 1, 40, 6 );
  19.     do {
  20.         cprintf("in thread #1.%lu %inr", arg, i);
  21.         i++;
  22.         j++;
  23.         rt_yield();
  24.     } while ( 1 );
  25. }
  26. /*********************************************************/
  27. void test2(DWORD arg)
  28. {
  29.     int i;
  30.     kwindow( 41, 1, 80, 6 );
  31.     for ( i = 0 ; i < 6000; ++i ) {
  32.         cprintf("in thread #2.%lu %inr", arg, i );
  33.         rt_yield();
  34.     }
  35.     cprintf("done thread, exitting");
  36. //  uncomment next line to start this thread anew each time it closes
  37. //    rt_newthread( test2, arg+1, 16536, 0, "worker 2" );
  38. }
  39. /*********************************************************/
  40. void timer(DWORD arg)
  41. {
  42.     time_t x;
  43.     kwindow( 1, 16, 80, 25 );
  44.     arg++;
  45.     do {
  46.         time( &x );
  47.         gotoxy( 1, 1 );
  48.         cprintf("%srn%u blk  %lu free %lu threads     ", ctime( &x ), kblocked,kcorefree(), knumthreads());
  49.         rt_sleep( 1000 );
  50.     } while( 1 );
  51. }
  52. /*********************************************************/
  53. int main(int argc, char **argv)
  54. {
  55.     int i;
  56.     // changing the next line would all that is needed to make this
  57.     // a pre-emptive multithreaded application
  58.     kpreemptive = 0;
  59.     kdebug = 1;
  60.     rt_init(100);
  61.     kwindow( 1, 6, 80, 16 );
  62.     cputs("starting...rn");
  63.     rt_newthread( timer, 0,4096, 0, "timer" );
  64.     rt_newthread( test,  1,4096, 0, "worker 1" );
  65.     rt_newthread( test2, 2,4096, 0, "worker 2" );
  66.     for ( i = 0 ; i < 1000 ; ++i ) {
  67.         rt_sleep( 10 );
  68.         cprintf("in main %inr", i);
  69.     }
  70. }