开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 操作系统开发 > 查看源码
TEST17.C
资源名称：ertos.rar　[点击查看]
上传用户：sunrenlu
上传日期：2022-06-13
资源大小：1419k
文件大小：2k
源码类别：

操作系统开发

开发平台：

DOS

TEST17.C：源码内容
  1. /**************************************************************************/
  2. /* test17 - shows results of slow message reads                           */
  3. /*          Suppose you have two threads communicating using the messaging*/
  4. /*          functions.  If the reader reads more slowly than the writer   */
  5. /*          sends, soon the message queue will become depleted.           */
  6. /*          Then other operations - like rt_sleep - may be affected as    */
  7. /*          there is no space on the message queue for their messages     */
  8. /*          To demonstrate this, we are using a very small message queue  */
  9. /*          and note that the sender eventually locks in at 5 messages    */
  10. /*          ahead of the sender.  rt_sleep( 200 ) will wait longer than   */
  11. /*          200 ms because sleep has no messages available to inform the  */
  12. /*          sleeping client to wake up.                                   */
  13. /**************************************************************************/
  15. #include "rtos.h"
  16. #include <stdio.h>
  17. #include <stdlib.h>
  19. void *peer = NULL;
  21. void switcher1(DWORD arg)
  22. {
  23.     int x;
  25. #if defined(__TURBOC__)||defined(__BORLANDC__)
  26.     randomize();
  27. #else
  28.     srand( time( 0 ) );
  29. #endif
  30.     
  32.     do {
  33.         x = rand();
  34.         cprintf( " sending %u ", x );
  35.         kwritemessage( peer, x, 0 );
  36.         rt_sleep(200);
  37.     } while ( 1 );
  38. }
  39. void switcher2(DWORD arg)
  40. {
  41.     int x;
  42.     DWORD y;
  43.     do {
  44.         if (kgetmessage( &x, &y ) ) {
  45.             cprintf(" read %u rn", x );
  46.             for(y=0; y<=20000000L; y++); // for instance waiting for a serial port answer
  47.             printf("Oo");
  48.         }
  49.      } while ( 1 );
  50. }
  52. main()
  53. {
  54.     kdebug = 1;
  55.     kpreemptive = 1;  // preemtive because switcher2 does not switch away
  56.     rt_init(5);       // a VERY small message queue size to demo this problem
  57.     cputs("starting...rn");
  58.     peer = rt_newthread( switcher2, 2, 4096, 1, "worker2" );
  59.     rt_newthread( switcher1, 1, 4096, 1, "worker1" );
  60.     while ( 1 ) rt_sleep( 10000 );
  61. }