免费注册 查看新帖 |

Chinaunix

  平台 论坛 博客 文库
› 论坛 › 程序设计 › C/C++ › 开个线程连mysql为啥占用虚存特别多呢。。
最近访问板块 发新帖
查看: 1499 | 回复: 0
打印 上一主题 下一主题

开个线程连mysql为啥占用虚存特别多呢。。 [复制链接]

ww2000e

论坛徽章:
0
跳转到指定楼层
1楼 [收藏(0)] [报告]
发表于 2012-04-26 13:54 |只看该作者 |倒序浏览
第一个占用180m，第二个占用108m  ，怎么这么大阿，代码没问题吧

编译 gcc t.c -lmysqlclient -lpthread
  1. #include <stdio.h>
  2. #include <pthread.h>
  3. #include <mysql/mysql.h>


  6. void *test1( void *arg )
  7. {
  8.         char sql[1024];
  9.         MYSQL_RES *results;
  10.         MYSQL_ROW record;
  11.         unsigned long id = 0;
  12.         MYSQL *mysql;
  13.         int mysql_timeout = 10;
  14.        
  15.         mysql = mysql_init( NULL );

  17.         mysql_options( mysql, MYSQL_OPT_CONNECT_TIMEOUT, &mysql_timeout );

  19.         if ( !mysql_real_connect( mysql, "localhost", "root", "123456","mydb", 0, NULL, 0 ) )
  20.         {
  21.                 printf("error");
  22.                 exit(1);
  23.         }
  24.        
  25.         while( 1 )
  26.         {
  27.                 snprintf( sql, 1024, "select * from test limit %ld,10", id ++ );
  28.                        
  29.                 if ( mysql_query( mysql, sql ) != 0 )
  30.                 {
  31.                         printf( "1 mysql:%s\n", mysql_error( mysql ) );
  32.                 }
  33.        
  34.                 results = mysql_store_result( mysql );

  36.                 if ( results == NULL )
  37.                 {
  38.                         printf( "2 mysql:%s\n", mysql_error( mysql ) );
  39.                 }

  41.                 while ( (record = mysql_fetch_row( results ) ) )
  42.                 {
  43.                         printf("%s - %s\n", record[0], record[1] );
  44.                 }

  46.                 if ( mysql_num_rows( results ) == 0 )
  47.                 {
  48.                         id = 0;
  49.                 }
  50.                
  51.                 mysql_free_result( results );
  52.         }

  54.         return arg;
  55. }

  57. void *test2( void *arg )
  58. {
  59.         char sql[1024], str[1024];
  60.         int id = 0;
  61.         MYSQL *mysql;
  62.         int mysql_timeout = 10;
  63.        
  64.         mysql = mysql_init( NULL );

  66.         mysql_options( mysql, MYSQL_OPT_CONNECT_TIMEOUT, &mysql_timeout );

  68.         sleep( 2 );
  69.        
  70.         if ( !mysql_real_connect( mysql, "localhost", "root",  "123456","mydb", 0, NULL, 0 ) )
  71.         {
  72.                 printf("error");
  73.                 exit(1);
  74.         }
  75.        
  76.         while ( 1 )
  77.         {
  78.                 snprintf( str, 1024, "wangwei %d", id );
  79.                
  80.                 snprintf( sql, 1024, "insert into test values (%ld,'%s')", id ++, str );

  82.                 if ( mysql_query( mysql, sql ) != 0 )
  83.                 {
  84.                         printf( "1 mysql:%s\n", mysql_error( mysql ) );
  85.                 }
  86.                
  87.                 printf("+");
  88.         }
  89.        
  90.         return arg;
  91. }


  94. main()
  95. {
  96.         int status;
  97.         pthread_t id1, id2;       

  99.         printf("mysql_thread_safe = %d\n",mysql_thread_safe());

  101.        
  102.         status = pthread_create( &id1, NULL, test1, NULL );
  103.        
  104.         if (status != 0)
  105.         {
  106.                 perror("thread1");
  107.                 exit(0);
  108.         }

  110.         status = pthread_create( &id2, NULL, test2, NULL );

  112.         if (status != 0)
  113.         {
  114.                 perror("thread2");
  115.                 exit(0);
  116.         }

  118.         while(1);
  119. }
复制代码
  1. #include <stdio.h>
  2. #include <pthread.h>
  3. #include <mysql/mysql.h>

  5. pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;


  8. void *test1( void *arg )
  9. {
  10.         char sql[1024];
  11.         MYSQL_RES *results;
  12.         MYSQL_ROW record;
  13.         unsigned long id = 0;
  14.         MYSQL *mysql;
  15.         int mysql_timeout = 10;
  16.        
  17.         mysql = ( MYSQL *) arg;
  18.         //mysql_options( mysql, MYSQL_OPT_CONNECT_TIMEOUT, &mysql_timeout );
  19.        
  20.         while( 1 )
  21.         {
  22.                 pthread_mutex_lock( &mutex );
  23.                
  24.                 snprintf( sql, 1024, "select * from test limit %ld,1", id ++ );
  25.                        
  26.                 if ( mysql_query( mysql, sql ) != 0 )
  27.                 {
  28.                         printf( "1 mysql:%s\n", mysql_error( mysql ) );
  29.                 }
  30.        
  31.                 results = mysql_store_result( mysql );

  33.                 if ( results == NULL )
  34.                 {
  35.                         printf( "2 mysql:%s\n", mysql_error( mysql ) );
  36.                 }

  38.                 while ( (record = mysql_fetch_row( results ) ) )
  39.                 {
  40.                         printf("%s - %s\n", record[0], record[1] );
  41.                 }

  43.                 if ( mysql_num_rows( results ) == 0 )
  44.                 {
  45.                         id = 0;
  46.                 }
  47.                
  48.                 mysql_free_result( results );
  49.                
  50.                 pthread_mutex_unlock( &mutex );
  51.         }

  53.         return arg;
  54. }

  56. void *test2( void *arg )
  57. {
  58.         char sql[1024], str[1024];
  59.         int id = 0;
  60.         MYSQL *mysql;
  61.         int mysql_timeout = 10;

  63.         mysql = ( MYSQL *) arg;
  64.         //mysql_options( mysql, MYSQL_OPT_CONNECT_TIMEOUT, &mysql_timeout );

  66.         sleep( 2 );

  68.         while ( 1 )
  69.         {
  70.                 pthread_mutex_lock( &mutex );
  71.                 snprintf( str, 1024, "wangwei %d", id );
  72.                
  73.                 snprintf( sql, 1024, "insert into test values (%ld,'%s')", id ++, str );

  75.                 if ( mysql_query( mysql, sql ) != 0 )
  76.                 {
  77.                         printf( "1 mysql:%s\n", mysql_error( mysql ) );
  78.                 }
  79.                
  80.                 printf("+");
  81.                
  82.                 pthread_mutex_unlock( &mutex );
  83.         }
  84.        
  85.         return arg;
  86. }


  89. main()
  90. {
  91.         int status;
  92.         pthread_t id1, id2;       
  93.         MYSQL *mysql;
  94.        
  95.         printf("mysql_thread_safe = %d\n",mysql_thread_safe());
  96.        
  97.         mysql = mysql_init( NULL );

  99.         if ( !mysql_real_connect( mysql, "localhost", "root", "123456","mydb", 0, NULL, 0 ) )
  100.         {
  101.                 printf("error");
  102.                 exit(1);
  103.         }
  104.        
  105.         status = pthread_create( &id1, NULL, test1, (void*)mysql );
  106.        
  107.         if (status != 0)
  108.         {
  109.                 perror("thread1");
  110.                 exit(0);
  111.         }

  113.         status = pthread_create( &id2, NULL, test2, (void*)mysql );

  115.         if (status != 0)
  116.         {
  117.                 perror("thread2");
  118.                 exit(0);
  119.         }

  121.         while(1);
  122. }
复制代码
返回列表 发新帖
高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 注册

本版积分规则 发表回复

  

北京盛拓优讯信息技术有限公司. 版权所有 京ICP备16024965号-6 北京市公安局海淀分局网监中心备案编号：11010802020122 niuxiaotong@pcpop.com 17352615567
未成年举报专区
中国互联网协会会员  联系我们：huangweiwei@itpub.net
感谢所有关心和支持过ChinaUnix的朋友们 转载本站内容请注明原作者名及出处

清除 Cookies - ChinaUnix - Archiver - WAP - TOP