| 
														
															@@ -157,8 +157,11 @@ class TestExclusiveLock: 
														 | 
													
												
											
												
													
														| 
														 | 
														
															         exception_counter = SynchronizedCounter() 
														 | 
														
														 | 
														
															         exception_counter = SynchronizedCounter() 
														 | 
													
												
											
												
													
														| 
														 | 
														
															         print_lock = ThreadingLock() 
														 | 
														
														 | 
														
															         print_lock = ThreadingLock() 
														 | 
													
												
											
												
													
														| 
														 | 
														
															         thread = None 
														 | 
														
														 | 
														
															         thread = None 
														 | 
													
												
											
												
													
														| 
														 | 
														
															 
														 | 
														
														 | 
														
															+        host_id, process_id = "differenthost", 1234 
														 | 
													
												
											
												
													
														| 
														 | 
														
															         for thread_id in range(RACE_TEST_NUM_THREADS): 
														 | 
														
														 | 
														
															         for thread_id in range(RACE_TEST_NUM_THREADS): 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-            thread = Thread(target=acquire_release_loop, args=(('foo', thread_id, 0), RACE_TEST_DURATION, thread_id, lock_owner_counter, exception_counter, print_lock, thread)) 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															 
														 | 
														
														 | 
														
															+            thread = Thread(target=acquire_release_loop, 
														 | 
													
												
											
												
													
														| 
														 | 
														
															 
														 | 
														
														 | 
														
															+                            args=((host_id, process_id, thread_id), RACE_TEST_DURATION, thread_id, 
														 | 
													
												
											
												
													
														| 
														 | 
														
															 
														 | 
														
														 | 
														
															+                                  lock_owner_counter, exception_counter, print_lock, thread)) 
														 | 
													
												
											
												
													
														| 
														 | 
														
															             thread.start() 
														 | 
														
														 | 
														
															             thread.start() 
														 | 
													
												
											
												
													
														| 
														 | 
														
															         thread.join()  # joining the last thread 
														 | 
														
														 | 
														
															         thread.join()  # joining the last thread 
														 | 
													
												
											
												
													
														| 
														 | 
														
															  
														 | 
														
														 | 
														
															  
														 |