Commit c11bb821 authored by Jim Fulton's avatar Jim Fulton

Changed to allow the number of threads to be configured.

parent 63660e55
......@@ -85,4 +85,18 @@
import ZRendezvous
handle=ZRendezvous.ZRendevous().handle
_handle=None
_n=1
def handle(*args, **kw):
global _handle
if _handle is None: _handle=ZRendezvous.ZRendevous(_n).handle
return apply(_handle, args, kw)
def setNumberOfThreads(n):
global _n
_n=n
global setNumberOfThreads
del setNumberOfThreads
......@@ -85,4 +85,18 @@
import ZRendezvous
handle=ZRendezvous.ZRendevous().handle
_handle=None
_n=1
def handle(*args, **kw):
global _handle
if _handle is None: _handle=ZRendezvous.ZRendevous(_n).handle
return apply(_handle, args, kw)
def setNumberOfThreads(n):
global _n
_n=n
global setNumberOfThreads
del setNumberOfThreads
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment