NumberServices unit test added

Author: pyscripter

Demos/Demo22/threading_test.py

@@ -0,0 +1,96 @@
+from threading import *
+from collections import deque
+from time import sleep
+
+def _test():
+
+ class BoundedQueue():
+
+ def __init__(self, limit):
+ self.mon = RLock()
+ self.rc = Condition(self.mon)
+ self.wc = Condition(self.mon)
+ self.limit = limit
+ self.queue = deque()
+
+ def put(self, item):
+ self.mon.acquire()
+ while len(self.queue) >= self.limit:
+ self._note("put(%s): queue full", item)
+ self.wc.wait()
+ self.queue.append(item)
+ self._note("put(%s): appended, length now %d",
+ item, len(self.queue))
+ self.rc.notify()
+ self.mon.release()
+
+ def get(self):
+ self.mon.acquire()
+ while not self.queue:
+ self._note("get(): queue empty")
+ self.rc.wait()
+ item = self.queue.popleft()
+ self._note("get(): got %s, %d left", item, len(self.queue))
+ self.wc.notify()
+ self.mon.release()
+ return item
+
+ def _note(self, format, *args):
+ format = format % args
+ ident = get_ident()
+ try:
+ name = current_thread().name
+ except KeyError:
+ name = "<OS thread %d>" % ident
+ format = "%s: %s" % (name, format)
+ print(format)
+
+ class ProducerThread(Thread):
+
+ def __init__(self, queue, quota):
+ Thread.__init__(self, name="Producer")
+ self.queue = queue
+ self.quota = quota
+
+ def run(self):
+ from random import random
+ counter = 0
+ while counter < self.quota:
+ counter = counter + 1
+ self.queue.put("%s.%d" % (self.name, counter))
+ sleep(random() * 0.00001)
+
+
+ class ConsumerThread(Thread):
+
+ def __init__(self, queue, count):
+ Thread.__init__(self, name="Consumer")
+ self.queue = queue
+ self.count = count
+
+ def run(self):
+ while self.count > 0:
+ item = self.queue.get()
+ print(item)
+ self.count = self.count - 1
+
+ NP = 3
+ QL = 4
+ NI = 5
+
+ Q = BoundedQueue(QL)
+ P = []
+ for i in range(NP):
+ t = ProducerThread(Q, NI)
+ t.name = ("Producer-%d" % (i+1))
+ P.append(t)
+ C = ConsumerThread(Q, NI*NP)
+ for t in P:
+ t.start()
+ sleep(0.000001)
+ C.start()
+ for t in P:
+ t.join()
+ C.join()
+
+_test()

Source/PythonEngine.pas

@@ -4345,7 +4345,7 @@ function TPythonEngine.IsType(ob: PPyObject; obt: PPyTypeObject): Boolean;
  result := ob^.ob_type = obt;
 end;
 
-function  TPythonEngine.EvalPyFunction(pyfunc, pyargs:PPyObject): Variant;
+function TPythonEngine.EvalPyFunction(pyfunc, pyargs:PPyObject): Variant;
 var presult :PPyObject;
 begin
  CheckPython;
@@ -4378,7 +4378,7 @@ function TPythonEngine.EvalPyFunction(pyfunc, pyargs:PPyObject): Variant;
  end;
 end;
 
-function  TPythonEngine.EvalFunction(pyfunc:PPyObject; args: array of const): Variant;
+function TPythonEngine.EvalFunction(pyfunc:PPyObject; args: array of const): Variant;
 var pargs: PPyObject;
 begin
  CheckPython;
@@ -4390,7 +4390,7 @@ function TPythonEngine.EvalFunction(pyfunc:PPyObject; args: array of const): V
  end;
 end;
 
-function  TPythonEngine.EvalFunctionNoArgs(pyfunc:PPyObject): Variant;
+function TPythonEngine.EvalFunctionNoArgs(pyfunc:PPyObject): Variant;
 var pargs: PPyObject;
 begin
  CheckPython;
@@ -4402,12 +4402,12 @@ function TPythonEngine.EvalFunctionNoArgs(pyfunc:PPyObject): Variant;
  end;
 end;
 
-function  TPythonEngine.EvalStringAsStr(const command : AnsiString) : string;
+function TPythonEngine.EvalStringAsStr(const command : AnsiString) : string;
 begin
  Result := Run_CommandAsString( command, eval_input );
 end;
 
-function  TPythonEngine.EvalString(const command : AnsiString) : PPyObject;
+function TPythonEngine.EvalString(const command : AnsiString) : PPyObject;
 begin
  Result := Run_CommandAsObject( command, eval_input );
 end;
@@ -4417,7 +4417,7 @@ procedure TPythonEngine.ExecString(const command : AnsiString);
  Py_XDecRef( Run_CommandAsObject( command, file_input ) );
 end;
 
-function  TPythonEngine.Run_CommandAsString(const command : AnsiString; mode : Integer) : string;
+function TPythonEngine.Run_CommandAsString(const command : AnsiString; mode : Integer) : string;
 var
  v : PPyObject;
 begin
@@ -4427,7 +4427,7 @@ function TPythonEngine.Run_CommandAsString(const command : AnsiString; mode :
  Py_XDECREF(v);
 end;
 
-function  TPythonEngine.Run_CommandAsObject(const command : AnsiString; mode : Integer) : PPyObject;
+function TPythonEngine.Run_CommandAsObject(const command : AnsiString; mode : Integer) : PPyObject;
 begin
  Result := Run_CommandAsObjectWithDict(command, mode, nil, nil);
 end;