MySQL数据库

开发平台：

Visual C++

test_select.c：源码内容

							#include <pthread.h>
#include <stdio.h>
#ifndef ultrix
#include <sys/fcntl.h>
#else /* ultrix */
#include <fcntl.h>
#endif /* !ultrix */
#include <sys/types.h>
#include <sys/time.h>
#ifdef hpux
#include <sys/file.h>
#endif /* hpux */
#include <errno.h>
#define NLOOPS 1000
int ntouts = 0;
void *
bg_routine(void *arg)
{
  write(1,"bg routine runningn",19);
  /*pthread_dump_state();*/
  while (1) {
    int n;
    char dot;
    dot = '.';
    pthread_yield();
    write(1,&dot,1);
    pthread_yield();
    n = NLOOPS;
    while (n-- > 0)
      pthread_yield();
  }
}
void *
fg_routine(void *arg)
{
  int flags, stat, nonblock_flag;
  static struct timeval tout = { 0, 500000 };
#if 0
#if defined(hpux) || defined(__alpha)
  nonblock_flag = O_NONBLOCK;
#else
  nonblock_flag = FNDELAY;
#endif
  printf("fg_routine runningn");
  flags = fcntl(0, F_GETFL, 0);
  printf("stdin flags b4 anything = %xn", flags);
  stat = fcntl(0, F_SETFL, flags | nonblock_flag);
  if (stat < 0) {
    printf("fcntl(%x) => %dn", nonblock_flag, errno);
    printf("could not set nonblocking i/o on stdin [oldf %x, stat %d]n",
	   flags, stat);
    exit(1);
  }
  printf("stdin flags = 0x%x after turning on %xn", flags, nonblock_flag);
#endif
  while (1) {
    int n;
    fd_set r;
    FD_ZERO(&r);
    FD_SET(0,&r);
    printf("select>");
    n = select(1, &r, (fd_set*)0, (fd_set*)0, (struct timeval *)0);
    if (n < 0) {
      perror ("select");
      exit(1);
    } else if (n > 0) {
      int nb;
      char buf[128];
      printf("=> select returned: %dn", n);
      while ((nb = read(0, buf, sizeof(buf)-1)) >= 0) {
	buf[nb] = '';
	printf("read %d: |%s|n", nb, buf);
      }
      printf("=> out of read loop: %d / %dn", nb, errno);
      if (nb < 0) {
	if (errno != EWOULDBLOCK && errno != EAGAIN) {
	  perror ("read");
	  exit(1);
	}
      }
    } else
      ntouts++;
  }
}
main(int argc, char **argv)
{
  pthread_t bg_thread, fg_thread;
  int junk;
  pthread_init();
  setbuf(stdout,NULL);
  setbuf(stderr,NULL);
  if (argc > 1) {
    if (pthread_create(&bg_thread, NULL, bg_routine, 0) < 0) {
      printf("error: could not create bg threadn");
      exit(1);
    }
  }
  if (pthread_create(&fg_thread, NULL, fg_routine, 0) < 0) {
    printf("error: could not create fg threadn");
    exit(1);
  }
  printf("threads forked: bg=%lx fg=%lxn", bg_thread, fg_thread);
  /*pthread_dump_state();*/
  printf("initial thread %lx joining fg...n", pthread_self());
  pthread_join(fg_thread, (void **)&junk);
}

						