mirror of
https://github.com/python/cpython.git
synced 2025-08-31 05:58:33 +00:00
Issue 11929: Minor whitespace clean-ups.
This commit is contained in:
parent
30fe8188b4
commit
40fc59d98b
7 changed files with 26 additions and 17 deletions
|
@ -47,7 +47,8 @@ class DBUnpickler(pickle.Unpickler):
|
||||||
|
|
||||||
|
|
||||||
def main():
|
def main():
|
||||||
import io, pprint
|
import io
|
||||||
|
import pprint
|
||||||
|
|
||||||
# Initialize and populate our database.
|
# Initialize and populate our database.
|
||||||
conn = sqlite3.connect(":memory:")
|
conn = sqlite3.connect(":memory:")
|
||||||
|
|
|
@ -5,7 +5,12 @@
|
||||||
# All rights reserved.
|
# All rights reserved.
|
||||||
#
|
#
|
||||||
|
|
||||||
import time, sys, multiprocessing, threading, queue, gc
|
import time
|
||||||
|
import sys
|
||||||
|
import multiprocessing
|
||||||
|
import threading
|
||||||
|
import queue
|
||||||
|
import gc
|
||||||
|
|
||||||
if sys.platform == 'win32':
|
if sys.platform == 'win32':
|
||||||
_timer = time.clock
|
_timer = time.clock
|
||||||
|
@ -111,7 +116,7 @@ def test_seqspeed(seq):
|
||||||
for i in range(iterations):
|
for i in range(iterations):
|
||||||
a = seq[5]
|
a = seq[5]
|
||||||
|
|
||||||
elapsed = _timer()-t
|
elapsed = _timer() - t
|
||||||
|
|
||||||
print(iterations, 'iterations in', elapsed, 'seconds')
|
print(iterations, 'iterations in', elapsed, 'seconds')
|
||||||
print('average number/sec:', iterations/elapsed)
|
print('average number/sec:', iterations/elapsed)
|
||||||
|
@ -132,7 +137,7 @@ def test_lockspeed(l):
|
||||||
l.acquire()
|
l.acquire()
|
||||||
l.release()
|
l.release()
|
||||||
|
|
||||||
elapsed = _timer()-t
|
elapsed = _timer() - t
|
||||||
|
|
||||||
print(iterations, 'iterations in', elapsed, 'seconds')
|
print(iterations, 'iterations in', elapsed, 'seconds')
|
||||||
print('average number/sec:', iterations/elapsed)
|
print('average number/sec:', iterations/elapsed)
|
||||||
|
@ -169,7 +174,7 @@ def test_conditionspeed(Process, c):
|
||||||
c.notify()
|
c.notify()
|
||||||
c.wait()
|
c.wait()
|
||||||
|
|
||||||
elapsed = _timer()-t
|
elapsed = _timer() - t
|
||||||
|
|
||||||
c.release()
|
c.release()
|
||||||
p.join()
|
p.join()
|
||||||
|
|
|
@ -25,18 +25,18 @@ def calculatestar(args):
|
||||||
return calculate(*args)
|
return calculate(*args)
|
||||||
|
|
||||||
def mul(a, b):
|
def mul(a, b):
|
||||||
time.sleep(0.5*random.random())
|
time.sleep(0.5 * random.random())
|
||||||
return a * b
|
return a * b
|
||||||
|
|
||||||
def plus(a, b):
|
def plus(a, b):
|
||||||
time.sleep(0.5*random.random())
|
time.sleep(0.5 * random.random())
|
||||||
return a + b
|
return a + b
|
||||||
|
|
||||||
def f(x):
|
def f(x):
|
||||||
return 1.0 / (x-5.0)
|
return 1.0 / (x - 5.0)
|
||||||
|
|
||||||
def pow3(x):
|
def pow3(x):
|
||||||
return x**3
|
return x ** 3
|
||||||
|
|
||||||
def noop(x):
|
def noop(x):
|
||||||
pass
|
pass
|
||||||
|
|
|
@ -5,7 +5,9 @@
|
||||||
# All rights reserved.
|
# All rights reserved.
|
||||||
#
|
#
|
||||||
|
|
||||||
import time, sys, random
|
import time
|
||||||
|
import sys
|
||||||
|
import random
|
||||||
from queue import Empty
|
from queue import Empty
|
||||||
|
|
||||||
import multiprocessing # may get overwritten
|
import multiprocessing # may get overwritten
|
||||||
|
@ -237,9 +239,9 @@ def test(namespace=multiprocessing):
|
||||||
|
|
||||||
multiprocessing = namespace
|
multiprocessing = namespace
|
||||||
|
|
||||||
for func in [ test_value, test_queue, test_condition,
|
for func in [test_value, test_queue, test_condition,
|
||||||
test_semaphore, test_join_timeout, test_event,
|
test_semaphore, test_join_timeout, test_event,
|
||||||
test_sharedvalues ]:
|
test_sharedvalues]:
|
||||||
|
|
||||||
print('\n\t######## %s\n' % func.__name__)
|
print('\n\t######## %s\n' % func.__name__)
|
||||||
func()
|
func()
|
||||||
|
|
|
@ -24,7 +24,7 @@ if sys.platform == 'win32':
|
||||||
|
|
||||||
|
|
||||||
def note(format, *args):
|
def note(format, *args):
|
||||||
sys.stderr.write('[%s]\t%s\n' % (current_process().name, format%args))
|
sys.stderr.write('[%s]\t%s\n' % (current_process().name, format % args))
|
||||||
|
|
||||||
|
|
||||||
class RequestHandler(SimpleHTTPRequestHandler):
|
class RequestHandler(SimpleHTTPRequestHandler):
|
||||||
|
@ -45,7 +45,7 @@ def runpool(address, number_of_processes):
|
||||||
server = HTTPServer(address, RequestHandler)
|
server = HTTPServer(address, RequestHandler)
|
||||||
|
|
||||||
# create child processes to act as workers
|
# create child processes to act as workers
|
||||||
for i in range(number_of_processes-1):
|
for i in range(number_of_processes - 1):
|
||||||
Process(target=serve_forever, args=(server,)).start()
|
Process(target=serve_forever, args=(server,)).start()
|
||||||
|
|
||||||
# main process also acts as a worker
|
# main process also acts as a worker
|
||||||
|
|
|
@ -1,5 +1,6 @@
|
||||||
import sqlite3
|
import sqlite3
|
||||||
import datetime, time
|
import datetime
|
||||||
|
import time
|
||||||
|
|
||||||
def adapt_datetime(ts):
|
def adapt_datetime(ts):
|
||||||
return time.mktime(ts.timetuple())
|
return time.mktime(ts.timetuple())
|
||||||
|
|
|
@ -27,7 +27,7 @@ class FixedOffset(tzinfo):
|
||||||
"""Fixed offset in minutes east from UTC."""
|
"""Fixed offset in minutes east from UTC."""
|
||||||
|
|
||||||
def __init__(self, offset, name):
|
def __init__(self, offset, name):
|
||||||
self.__offset = timedelta(minutes = offset)
|
self.__offset = timedelta(minutes=offset)
|
||||||
self.__name = name
|
self.__name = name
|
||||||
|
|
||||||
def utcoffset(self, dt):
|
def utcoffset(self, dt):
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue