add SetDefaultWorkerPoolSettings()

Author: johnteee

worker/pool.go

@@ -32,8 +32,8 @@ type WorkerPool interface {
 	ScheduleWithTimeout(func(), time.Duration) error
 }
 
-// DefaultWorkerSettings Settings for DefaultWorkerPool
-type DefaultWorkerSettings struct {
+// DefaultWorkerPoolSettings Settings for DefaultWorkerPool
+type DefaultWorkerPoolSettings struct {
 	// JobQueue
 
 	isJobQueueClosedWhenClose bool
@@ -57,7 +57,7 @@ var defaultPanicHandler = func(panic interface{}) {
 	log.Printf("panic from worker: %s\n", string(buf[:runtime.Stack(buf, false)]))
 }
 
-var defaultDefaultWorkerSettings = &DefaultWorkerSettings{
+var defaultDefaultWorkerSettings = &DefaultWorkerPoolSettings{
 	isJobQueueClosedWhenClose: true,
 	workerBatchSize:           5,
 	workerSizeStandBy:         5,
@@ -79,11 +79,11 @@ type DefaultWorkerPool struct {
 	lastAccessTime time.Time
 
 	// Settings
-	DefaultWorkerSettings
+	DefaultWorkerPoolSettings
 }
 
 // NewDefaultWorkerPool New a DefaultWorkerPool
-func NewDefaultWorkerPool(jobQueue *fpgo.BufferedChannelQueue[func()], settings *DefaultWorkerSettings) *DefaultWorkerPool {
+func NewDefaultWorkerPool(jobQueue *fpgo.BufferedChannelQueue[func()], settings *DefaultWorkerPoolSettings) *DefaultWorkerPool {
 	if settings == nil {
 		settings = defaultDefaultWorkerSettings
 	}
@@ -93,7 +93,7 @@ func NewDefaultWorkerPool(jobQueue *fpgo.BufferedChannelQueue[func()], settings
 		spawnWorkerCh: fpgo.NewChannelQueue[int](1),
 
 		// Settings
-		DefaultWorkerSettings: *settings,
+		DefaultWorkerPoolSettings: *settings,
 	}
 	go workerPool.spawnLoop()
 
@@ -263,6 +263,13 @@ func (workerPoolSelf *DefaultWorkerPool) SetWorkerExpiryDuration(workerExpiryDur
 	return workerPoolSelf
 }
 
+// SetDefaultWorkerPoolSettings Set the defaultWorkerPoolSettings
+func (workerPoolSelf *DefaultWorkerPool) SetDefaultWorkerPoolSettings(defaultWorkerPoolSettings DefaultWorkerPoolSettings) *DefaultWorkerPool {
+	workerPoolSelf.DefaultWorkerPoolSettings = defaultWorkerPoolSettings
+	workerPoolSelf.notifyWorkers()
+	return workerPoolSelf
+}
+
 // IsClosed Is the DefaultWorkerPool closed
 func (workerPoolSelf *DefaultWorkerPool) IsClosed() bool {
 	return workerPoolSelf.isClosed.Get()