Remove unused codes

Author: johnteee

worker/pool.go

@@ -80,10 +80,6 @@ type DefaultWorkerPool struct {
 	spawnWorkerCh fpgo.ChannelQueue[int]
 	lastAliveTime time.Time
 
-	// scheduleWaitQueue  fpgo.Queue[fpgo.ChannelQueue[int]]
-	// scheduleWaitChPool sync.Pool
-	// scheduleWaitCount int
-
 	// Settings
 	DefaultWorkerPoolSettings
 }
@@ -97,14 +93,10 @@ func NewDefaultWorkerPool(jobQueue *fpgo.BufferedChannelQueue[func()], settings
 		jobQueue: jobQueue,
 
 		spawnWorkerCh: fpgo.NewChannelQueue[int](1),
-		// scheduleWaitQueue: fpgo.NewConcurrentQueue[fpgo.ChannelQueue[int]](fpgo.NewLinkedListQueue[fpgo.ChannelQueue[int]]()),
 
 		// Settings
 		DefaultWorkerPoolSettings: *settings,
 	}
-	// workerPool.scheduleWaitChPool.New = func() interface{} {
-	// 	return fpgo.NewChannelQueue[int](1)
-	// }
 	go workerPool.spawnLoop()
 
 	return workerPool
@@ -197,33 +189,21 @@ func (workerPoolSelf *DefaultWorkerPool) generateWorkerWithMaximum(maximum int)
 			workerPoolSelf.lock.Lock()
 			workerPoolSelf.workerCount--
 			workerPoolSelf.lock.Unlock()
-			// fmt.Println("Terminated")
 		}()
 
 		// Do Jobs
 	loopLabel:
 		for {
 			workerPoolSelf.lastAliveTime = time.Now()
-			// workerPoolSelf.lock.RLock()
-			// if workerPoolSelf.scheduleWaitCount > 0 {
-			// 	ch, _ := workerPoolSelf.scheduleWaitQueue.Poll()
-			// 	if ch != nil {
-			// 		ch.Offer(1)
-			// 		defer workerPoolSelf.scheduleWaitChPool.Put(ch)
-			// 	}
-			// }
-			// workerPoolSelf.lock.RUnlock()
 
 			if workerPoolSelf.IsClosed() {
 				return
 			}
 
 			select {
 			case job := <-workerPoolSelf.jobQueue.GetChannel():
-				// fmt.Println("GetJob")
 				if job != nil {
 					job()
-					// fmt.Println("DoJob")
 				}
 			case <-time.After(workerPoolSelf.workerExpiryDuration):
 				workerPoolSelf.lock.RLock()
@@ -245,12 +225,6 @@ func (workerPoolSelf *DefaultWorkerPool) SetJobQueue(jobQueue *fpgo.BufferedChan
 	return workerPoolSelf
 }
 
-// // SetScheduleWaitQueue Set the ScheduleWaitQueue(WARNING: if the pool has started to use, doing this is not safe)
-// func (workerPoolSelf *DefaultWorkerPool) SetScheduleWaitQueue(scheduleWaitQueue fpgo.Queue[fpgo.ChannelQueue[int]]) *DefaultWorkerPool {
-// 	workerPoolSelf.scheduleWaitQueue = scheduleWaitQueue
-// 	return workerPoolSelf
-// }
-
 // SetIsJobQueueClosedWhenClose Set is the JobQueue closed when the WorkerPool.Close()
 func (workerPoolSelf *DefaultWorkerPool) SetIsJobQueueClosedWhenClose(isJobQueueClosedWhenClose bool) *DefaultWorkerPool {
 	workerPoolSelf.isJobQueueClosedWhenClose = isJobQueueClosedWhenClose
@@ -357,25 +331,12 @@ func (workerPoolSelf *DefaultWorkerPool) ScheduleWithTimeout(fn func(), timeout
 		return err
 	}
 
-	// if retry < 1 {
-	// 	retry = 1
-	// }
-	// retryInterval := timeout / time.Duration(retry+1)
 	retryInterval := workerPoolSelf.scheduleRetryInterval
 	if retryInterval > timeout/3 {
 		// retryInterval = timeout * 95 / 100 / 3
-		retryInterval = timeout/3
+		retryInterval = timeout / 3
 	}
 	deadline := time.Now().Add(timeout)
-	// workerPoolSelf.addScheduleWaitCount(1)
-	// defer workerPoolSelf.addScheduleWaitCount(-1)
-
-	// scheduleWaitCh := workerPoolSelf.scheduleWaitChPool.Get().(fpgo.ChannelQueue[int])
-	// defer workerPoolSelf.scheduleWaitChPool.Put(scheduleWaitCh)
-	// err = workerPoolSelf.scheduleWaitQueue.Offer(scheduleWaitCh)
-	// if err != nil {
-	// 	return err
-	// }
 
 	for {
 		if workerPoolSelf.IsClosed() {
@@ -387,29 +348,15 @@ func (workerPoolSelf *DefaultWorkerPool) ScheduleWithTimeout(fn func(), timeout
 			return err
 		}
 
-		// fmt.Println(retryInterval)
-		// fmt.Println(deadline.Sub(now))
 		if time.Now().After(deadline) {
 			return ErrWorkerPoolScheduleTimeout
 		}
 		time.Sleep(retryInterval)
 
-		// select {
-		// case <-scheduleWaitCh:
-		// 	continue
-		// case <-time.After(deadline.Sub(time.Now())):
-		// 	return ErrWorkerPoolScheduleTimeout
-		// }
 	}
 	return err
 }
 
-// func (workerPoolSelf *DefaultWorkerPool) addScheduleWaitCount(amount int) {
-// 	workerPoolSelf.lock.Lock()
-// 	workerPoolSelf.scheduleWaitCount += amount
-// 	workerPoolSelf.lock.Unlock()
-// }
-
 // Invokable
 
 // Invokable Invokable inspired by Java ExecutorService