File tree Expand file tree Collapse file tree 1 file changed +12
-12
lines changed Expand file tree Collapse file tree 1 file changed +12
-12
lines changed Original file line number Diff line number Diff line change @@ -596,18 +596,18 @@ func (pool *WorkerPool) RunLambda(w http.ResponseWriter, r *http.Request) {
596
596
597
597
// a simple load balancer based on worker's processed tasks
598
598
assigned := worker .workerId
599
- // var smallWorker *Worker
600
- // var smallWorkerTask int32
601
- // smallWorkerTask = 10000
602
- // for _, curWorker := range pool.workers[RUNNING] {
603
- // if curWorker.numTask < smallWorkerTask {
604
- // smallWorkerTask = curWorker.numTask
605
- // smallWorker = curWorker
606
- // }
607
- // }
608
- // if smallWorkerTask < (worker.numTask - 10 ) {
609
- // worker = smallWorker
610
- // }
599
+ var smallWorker * Worker
600
+ var smallWorkerTask int32
601
+ smallWorkerTask = 10000
602
+ for _ , curWorker := range pool .workers [RUNNING ] {
603
+ if curWorker .numTask < smallWorkerTask {
604
+ smallWorkerTask = curWorker .numTask
605
+ smallWorker = curWorker
606
+ }
607
+ }
608
+ if smallWorkerTask < (worker .numTask - 32 ) {
609
+ worker = smallWorker
610
+ }
611
611
612
612
// fmt.Printf("Debug: function %s assigned to %s\n", thisTask, assigned)
613
613
You can’t perform that action at this time.
0 commit comments