pymysql + gevent, почему дБ с несколькими сопрограммами занимает больше времени？ - PullRequest
Новая
       9

pymysql + gevent, почему дБ с несколькими сопрограммами занимает больше времени？

0 голосов
/ 03 сентября 2018

pymysql + gevent, почему многопрограммный запрос занимает больше времени?

время использования одного запроса: 0,6 мс 10 сопрограмм использовать 2,2 мс, почему каждый запрос использует время более 0,6 мс?

мой результат теста: 

pool start
[0]used time:0.000674962997437
[1]used time:0.000821113586426
[5]used time:0.000817775726318
[2]used time:0.00109195709229
[4]used time:0.00116109848022
[8]used time:0.00116205215454
[9]used time:0.00126385688782
[3]used time:0.00168299674988
[7]used time:0.00165200233459
[6]used time:0.00182700157166
pool end
use time: 0.002352

Мой стол: 

CREATE TABLE `user_info` (
 `id` int(11) NOT NULL,
 `name` varchar(255) NOT NULL,
 `sex` int(11) NOT NULL DEFAULT '0',
 PRIMARY KEY (`id`,`name`)
) ENGINE=InnoDB AUTO_INCREMENT=814 DEFAULT CHARSET=utf8;

мой скрипт на python для теста, он подключает БД, создает 10 сопрограмм для запроса SQL, общее использованное время может быть равно одному запросу, но не равно: 

#!/usr/bin/python
# -*- coding: utf-8 -*-
import gevent
from gevent.pool import Pool
from gevent import monkey
monkey.patch_all()
#monkey.patch_socket() 
import pymysql
import time 
import sys

size = 10
conn_list = []

def init_conn():
    for i in range(0, size):
        db = pymysql.connect(host = '127.0.0.1', port=13357, passwd = 'admin@123', user = 'admin_123', db= 'test')
        conn_list.append(db)

def deinit_conn():
    for i in range(0, size):
        conn_list[i].close()


def nbquery(fmt, index):
    cursor = conn_list[index].cursor()
    ts1 = time.time()
    #sql = fmt % (sub_odr_id[index%10])
    data = cursor.execute(fmt)
    ts2 = time.time()
    print('[%d]used time:%s' % (index, ts2 - ts1))
    cursor.close()


init_conn()
# sqlc="SELECT SLEEP(0.001)"
sqld="select * from user_info where id=2 and name='John'"
start = time.time()
print('pool start')
pool = Pool()
for i in range(0, size):
    pool.spawn(nbquery, (sqld), i)

pool.join()

print('pool end')
print('use time: %f' % (time.time() - start))
#deinit_conn()
...