- Fixing the leakage of process when the TKTWorker is GCed.

- Fixing the tests and improving.
- Improving the rest of the watchdog.

TaskIt-Tests/TKTCommonQueueWorkerPoolTest.class.st

@@ -49,7 +49,7 @@ TKTCommonQueueWorkerPoolTest >> testWorkerPoolDoesNotExceedPoolSizeWhenSchedulin
 	1 to: 10 do: [ :i | futures nextPut: (pool future: [ 10 timesRepeat: [ futures nextPut: (pool future: [ totalTasks := totalTasks + 1 ]) ] ]) ].
 	[ futures isEmpty ] whileFalse: [ futures next waitForCompletion: 100 milliSeconds ].
 	self assert: totalTasks equals: 100.
-	self assert: pool size equals: 10
+	self assert: pool size <= 10
 ]
 
 { #category : #tests }

TaskIt-Tests/TKTMemoryLeakTest.class.st

@@ -17,5 +17,5 @@ TKTMemoryLeakTest >> trackInstancesOf: aClass during: aBlock [
 
 	self garbageCollectAndWait .
 
-	self assert: before equals: aClass allInstances size.
+	self assert: before >= aClass allInstances size.
 ]

TaskIt/TKTConfiguration.class.st

@@ -130,6 +130,13 @@ TKTConfiguration class >> profiles [
 	^ TKTProfile profiles
 ]
 
+{ #category : #accessing }
+TKTConfiguration class >> resetSoleInstance [ 
+
+	TKTWatchDog reset.
+	super resetSoleInstance.
+]
+
 { #category : #accessing }
 TKTConfiguration class >> runner [
 	^ self optionAt: #runner

TaskIt/TKTWatchDog.class.st

@@ -23,6 +23,13 @@ TKTWatchDog class >> onDuty [
 			onDuty ]
 ]
 
+{ #category : #reseting }
+TKTWatchDog class >> reset [
+
+	onDuty ifNotNil: [ onDuty stop ].
+	onDuty := nil.
+]
+
 { #category : #initialization }
 TKTWatchDog >> cleanUpImageToStart [
 	values removeAll
@@ -60,6 +67,11 @@ TKTWatchDog >> name [
 	^ 'WatchDog (' , id asString , ')'
 ]
 
+{ #category : #'as yet unclassified' }
+TKTWatchDog >> pharoProcess [
+	^ worker process process
+]
+
 { #category : #initialization }
 TKTWatchDog >> privateStart [
 	stopRequested := false.

TaskIt/TKTWorker.class.st

@@ -73,14 +73,14 @@ TKTWorker >> exceptionHandler: aHandler [
 ]
 
 { #category : #finalization }
-TKTWorker >> finalize [
-	TKTConfiguration watchDog stopWatching: self.
-	self
-		schedule: [ | theProcess |
-			queue := nil.
-			theProcess := process.
-			theProcess ifNotNil: [ theProcess kill ].
-			process := nil ].
+TKTWorker >> executor [
+
+	"The finalization scheme runs in another object (the executor) that does not have 
+	all the state, if it has all the state a loop is generated and never GCed"
+
+	^ TKTWorkerExecutor new
+		processToKill: process;
+		yourself.
 ]
 
 { #category : #initialization }

TaskIt/TKTWorkerExecutor.class.st

@@ -0,0 +1,23 @@
+"
+I am an object that will be used as executor of the TKTWorker. 
+In that way I don't need to copy the TKTWorker and nilling its instance variables.
+"
+Class {
+	#name : #TKTWorkerExecutor,
+	#superclass : #Object,
+	#instVars : [
+		'processToKill'
+	],
+	#category : #'TaskIt-Worker'
+}
+
+{ #category : #finalization }
+TKTWorkerExecutor >> finalize [
+
+	(processToKill at: 1) ifNotNil: [:e | e kill]
+]
+
+{ #category : #accessing }
+TKTWorkerExecutor >> processToKill: anObject [
+	processToKill := WeakArray with: anObject
+]