Message11495

I was unable to reproduce this on my Windows box. Here's what I evolved Ivan's demonstration into:
import thread
import re
import time
import random
LEN = 2000
COUNT = 10000
REGEX = re.compile('((?:foo|bar)+)(\d*)E?')
counter = 0
counter_lock = thread.allocate_lock()
def count(inc=0):
 global counter
 with counter_lock:
 counter += inc
 return counter
 
def parse(line):
 try:
 m = REGEX.search(line)
 finally:
 count(1)
 if LEN <= 10 and m.groups():
 print line, m.group(1)
def make():
 nonsense = list()
 for i in range(LEN):
 nonsense.append(random.choice(('foo', 'bar')))
 nonsense.append(str(random.randint(1, 99999)))
 nonsense.append(random.choice(('', 'E')))
 return ''.join(nonsense)
# Make up material
tests = list()
for i in range(COUNT):
 tests.append(make())
print "Start all threads"
start = thread.start_new_thread
for test in tests:
 start(parse, (test,))
print "Wait for completion"
while True:
 c = count()
 print c
 if not c < COUNT:
 break
 time.sleep(0.1)
I know there's a lock here, but it doesn't interfere until after the threads complete.
I get:
 ..\inst\bin\jython .\iss2609_parse2.py
Start all threads
Wait for completion
9984
10000
and no exceptions. During the run, jvisualvm peaks at 1038 live threads and the resource monitor shows all 4 CPUs busy, so I think I'm getting as much concurrency out of it as I have available. I am using:
Jython 2.7.1 (default:0df7adb1b397, Jun 30 2017, 19:02:43)
[Java HotSpot(TM) 64-Bit Server VM (Oracle Corporation)] on java1.8.0_141