Optimize metrics aggregate/persistent worker: seperate OAL and MAL workers and consume pools, and make the consumer thread sleep when no data in.

[wankai123]

• If this pull request closes/resolves/fixes an existing issue, replace the issue number. Closes #.
• Update the CHANGES log.

Optimize metrics aggregate/persistent worker: seperate OAL and MAL workers and consume pools, and make the consumer thread sleep when no data in.

[Copilot]

Pull Request Overview

This PR optimizes the metrics aggregation and persistence processing by separating OAL (Observability Analysis Language) and MAL (Meter Analysis Language) workers into dedicated thread pools with different configurations. The key optimization introduces a notification-based consumption pattern for MAL workers to reduce unnecessary resource usage when no data is available.

• Separates OAL and MAL workers into dedicated worker classes with optimized configurations
• Introduces notification-based consumer thread sleeping for MAL workers to reduce CPU usage
• Updates the data carrier consumer pool to support notifiable consumption patterns

Reviewed Changes

Copilot reviewed 11 out of 11 changed files in this pull request and generated 4 comments.

Show a summary per file

File	Description
ConsumerPoolFactoryTest.java	Updates test to include new notifiable parameter in BulkConsumePool.Creator
MultipleChannelsConsumer.java	Adds notification-based consumption logic with sleep when no data
BulkConsumePool.java	Adds notifiable parameter and consumer notification capability
MetricsStreamProcessor.java	Implements factory pattern to create OAL/MAL specific workers
MetricsPersistentMinWorker.java	Converts to abstract base class with configurable pool parameters
MetricsPersistentMinOALWorker.java	OAL-specific persistent worker with optimized settings
MetricsPersistentMinMALWorker.java	MAL-specific persistent worker with notification support
MetricsAggregateWorker.java	Converts to abstract base class with configurable pool parameters
MetricsAggregateOALWorker.java	OAL-specific aggregate worker with high-throughput settings
MetricsAggregateMALWorker.java	MAL-specific aggregate worker with notification support
changes.md	Documents the optimization changes

---

_{Tip: Customize your code reviews with copilot-instructions.md. Create the file or learn how to get started.
You can also share your feedback on Copilot code review for a chance to win a $100 gift card. Take the survey.}