add AsyncFutureBeaconLogger [feenkcom/gtoolkit#3778]

src/GToolkit-Extensions/AsyncFutureCompositeLogger.extension.st

@@ -0,0 +1,10 @@
+Extension { #name : #AsyncFutureCompositeLogger }
+
+{ #category : #'*GToolkit-Extensions' }
+AsyncFutureCompositeLogger >> gtLoggersFor: aView [
+	<gtView>
+	^ aView columnedList
+		title: 'Loggers';
+		items: [ self loggers ];
+		column: 'Name' text: #yourself
+]

src/GToolkit-Extensions/AsyncFutureThreadPool.extension.st

@@ -17,7 +17,7 @@ AsyncFutureThreadPool >> gtEnableTelemetryActionFor: anAction [
 { #category : #'*GToolkit-Extensions' }
 AsyncFutureThreadPool >> gtWorkersFor: aView [
 	<gtView>
-	| aTelemetry |
+	| aTelemetry aMemoryLogger |
 
 	aTelemetry := self telemetryDo: #yourself ifNone: nil.
 
@@ -77,5 +77,10 @@ AsyncFutureThreadPool >> gtWorkersFor: aView [
 					ifNone: [ self telemetry: (aTelemetry := AsyncFutureThreadPoolTelemetry new) ] ];
 		actionButtonIcon: BrGlamorousVectorIcons cancel
 			tooltip: 'Reset telemetry'
-			action: [ self telemetryDo: #reset ]
+			action: [ self telemetryDo: #reset ];
+		actionButtonIcon: BrGlamorousVectorIcons right 
+			tooltip: 'Monitor pending tasks' 
+			action: [ :aButton | 
+				AsyncFutureThreadPoolWorker ensureDefaultLogger: AsyncFutureBeaconLogger new.
+				aButton phlow spawnObject: (aMemoryLogger ifNil: [ aMemoryLogger := MemoryLogger new startFor: AsyncFutureSignal]) ]
 ]

src/GToolkit-Monitor/AsyncFutureBeaconLogger.class.st

@@ -0,0 +1,14 @@
+Class {
+	#name : #AsyncFutureBeaconLogger,
+	#superclass : #Object,
+	#traits : 'TAsyncFutureLogger',
+	#classTraits : 'TAsyncFutureLogger classTrait',
+	#category : #'GToolkit-Monitor-Future Workers'
+}
+
+{ #category : #logging }
+AsyncFutureBeaconLogger >> pendingTask: aPendingTask [
+	AsyncFuturePendingTaskSignal new
+		pendingTask: aPendingTask;
+		emit
+]

src/GToolkit-Monitor/AsyncFuturePendingTaskSignal.class.st

@@ -0,0 +1,37 @@
+Class {
+	#name : #AsyncFuturePendingTaskSignal,
+	#superclass : #AsyncFutureSignal,
+	#instVars : [
+		'pendingTask'
+	],
+	#category : #'GToolkit-Monitor-Future Workers'
+}
+
+{ #category : #accessing }
+AsyncFuturePendingTaskSignal >> gtCompositionFor: aView [
+	<gtView>
+	^ aView forward
+		title: 'Pending task';
+		object: [ self pendingTask ];
+		view: #gtCompositionFor:
+]
+
+{ #category : #accessing }
+AsyncFuturePendingTaskSignal >> pendingTask [
+	<return: #AsyncFutureThreadPoolPendingTask>
+	^ pendingTask
+]
+
+{ #category : #accessing }
+AsyncFuturePendingTaskSignal >> pendingTask: aTask [
+	pendingTask := aTask
+]
+
+{ #category : #accessing }
+AsyncFuturePendingTaskSignal >> printOneLineContentsOn: stream [
+	pendingTask ifNil: [ ^ self ].
+	timestamp ifNil: [ ^ self ].
+
+	stream nextPutAll: 'After '.
+	(timestamp - pendingTask sinceTime) printHumanReadableOn: stream
+]

src/GToolkit-Monitor/AsyncFutureSignal.class.st

@@ -0,0 +1,5 @@
+Class {
+	#name : #AsyncFutureSignal,
+	#superclass : #BeaconSignal,
+	#category : #'GToolkit-Monitor-Future Workers'
+}