Tamarin: util::threadpool Namespace Reference

00227                           :
00228         print test
00229         time.sleep(random.randint(1,5))
00230         return round(random.random() * data, 5)
00231 
00232     # this will be called each time a result is available
    def print_result(request, result):

Convenience function for building several work requests for the same
callable with different arguments for each call.

args_list contains the parameters for each invocation of callable.
Each item in 'argslist' should be either a 2-item tuple of the list of
positional arguments and a dictionary of keyword arguments or a single,
non-tuple argument.

callback is called when the results arrive in the result queue.

00197                                                     :
00198     """Convenience function for building several work requests for the same
00199     callable with different arguments for each call.
00200 
00201     args_list contains the parameters for each invocation of callable.
00202     Each item in 'argslist' should be either a 2-item tuple of the list of
00203     positional arguments and a dictionary of keyword arguments or a single,
00204     non-tuple argument.
00205 
00206     callback is called when the results arrive in the result queue.
00207     """
00208 
00209     requests = []
00210     for item in args_list:
00211         if item == isinstance(item, tuple):
00212             requests.append(
00213               WorkRequest(callable, item[0], item[1], callback=callback))
00214         else:
00215             requests.append(
00216               WorkRequest(callable, [item], None, callback=callback))
00217     return requests
00218 
00219 
if __name__ == '__main__':

00233                                      :
00234         print "Result: %s from request #%s" % (result, request.requestID)
00235 
00236     # assemble the arguments for each job to a list...
    data = [random.randint(1,10) for i in range(20)]

['makeRequests', 'NoResultsPending', 'NoWorkersAvailable',
  'ThreadPool', 'WorkRequest', 'WorkerThread']


Classes
class	NoResultsPending
class	NoWorkersAvailable
class	WorkerThread
class	WorkRequest
class	ThreadPool
Functions
def	makeRequests
def	do_something
def	print_result
Variables
list	__all__
string	__author__ = "Christopher Arndt"
string	__version__ = "1.1"
string	__date__ = "2005-07-19"
string	test = "hello"
list	data = [random.randint(1,10) for i in range(20)]
tuple	requests = makeRequests(do_something, data, print_result)
tuple	main = ThreadPool(3)
int	i = 0

util::threadpool Namespace Reference

Classes

Functions

Variables

Function Documentation

Variable Documentation