diff --git a/pkg/services/policer/process.go b/pkg/services/policer/process.go
index 873a1efb..c4c82020 100644
--- a/pkg/services/policer/process.go
+++ b/pkg/services/policer/process.go
@@ -19,6 +19,7 @@ func (p *Policer) shardPolicyWorker(ctx context.Context) {
 	for {
 		select {
 		case <-ctx.Done():
+			p.taskPool.Release()
 			return
 		default:
 		}
@@ -36,6 +37,7 @@ func (p *Policer) shardPolicyWorker(ctx context.Context) {
 		for i := range addrs {
 			select {
 			case <-ctx.Done():
+				p.taskPool.Release()
 				return
 			default:
 				addr := addrs[i]