- 论坛徽章:
- 0
|
#!/usr/bin/env python
import MySQLdb, pp, time
import MySQLdb.cursors
conn = MySQLdb.connect (host = "192.168.1.254",user = "root",passwd = "000000",db = "test",cursorclass = MySQLdb.cursors.DictCursor)
cursor = conn.cursor()
#two=conn.cursor()
#two.execute ("select * from slevin")
sql="select * from slevin"
#row=two.fetchall()
ppservers = ("192.168.1.254",)
#ppservers = ("10.0.0.1",)
ncpus=2
job_server = pp.Server(ncpus, ppservers=ppservers)
#job1 = job_server.submit(sum_primes, (100,), (isprime,), ("math",))
def count(sql,n):
i=1
while i<=n:
cursor.execute(sql)
start_time = time.time()
job1 = job_server.submit(count, (sql,1000000,), (cursor.execute,), ("MySQLdb",))
print "Time elapsed: ", time.time() - start_time, "s"
cursor.close ()
conn.close ()
运行之后出现一下错误:
Traceback (most recent call last):
File "./test.py", line 20, in ?
job1 = job_server.submit(count, (sql,1000000,), (cursor.execute,), ("MySQLdb",))
File "/usr/lib/python2.3/site-packages/pp.py", line 449, in submit
sfunc = self.__dumpsfunc((func, ) + depfuncs, modules)
File "/usr/lib/python2.3/site-packages/pp.py", line 634, in __dumpsfunc
sources = [self.__get_source(func) for func in funcs]
File "/usr/lib/python2.3/site-packages/pp.py", line 713, in __get_source
sourcelines = inspect.getsourcelines(func)[0]
File "/usr/lib64/python2.3/inspect.py", line 538, in getsourcelines
lines, lnum = findsource(object)
File "/usr/lib64/python2.3/inspect.py", line 408, in findsource
raise IOError('could not get source code')
IOError: could not get source code |
|