Skip to content

Commit

Permalink
[ISSUE #301] remove @builder
Browse files Browse the repository at this point in the history
  • Loading branch information
KamToHung committed Jan 17, 2024
1 parent b9fb3e3 commit 2758fdb
Show file tree
Hide file tree
Showing 4 changed files with 21 additions and 30 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -17,10 +17,10 @@

package org.dromara.dynamictp.common.entity;

import lombok.Data;
import lombok.experimental.Accessors;
import org.dromara.dynamictp.common.em.NotifyItemEnum;
import org.dromara.dynamictp.common.util.DateUtil;
import lombok.Builder;
import lombok.Data;

import java.util.concurrent.atomic.AtomicInteger;

Expand All @@ -31,7 +31,7 @@
* @since 1.0.4
**/
@Data
@Builder
@Accessors(chain = true)
public class AlarmInfo {

private NotifyItemEnum notifyItem;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,13 +17,8 @@

package org.dromara.dynamictp.common.entity;

import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.NoArgsConstructor;




/**
Expand All @@ -33,9 +28,6 @@
* @since 1.0.0
**/
@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
@EqualsAndHashCode(callSuper = true)
public class ThreadPoolStats extends Metrics {

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -36,7 +36,8 @@
**/
public class ExecutorConverter {

private ExecutorConverter() { }
private ExecutorConverter() {
}

public static TpMainFields toMainFields(ExecutorWrapper executorWrapper) {
TpMainFields mainFields = new TpMainFields();
Expand Down Expand Up @@ -82,20 +83,20 @@ public static ThreadPoolStats toMetrics(ExecutorWrapper wrapper) {
}

private static ThreadPoolStats convertCommon(ExecutorAdapter<?> executor) {
return ThreadPoolStats.builder()
.corePoolSize(executor.getCorePoolSize())
.maximumPoolSize(executor.getMaximumPoolSize())
.poolSize(executor.getPoolSize())
.activeCount(executor.getActiveCount())
.largestPoolSize(executor.getLargestPoolSize())
.queueType(executor.getQueueType())
.queueCapacity(executor.getQueueCapacity())
.queueSize(executor.getQueueSize())
.queueRemainingCapacity(executor.getQueueRemainingCapacity())
.taskCount(executor.getTaskCount())
.completedTaskCount(executor.getCompletedTaskCount())
.waitTaskCount(executor.getQueueSize())
.rejectHandlerName(executor.getRejectHandlerType())
.build();
ThreadPoolStats poolStats = new ThreadPoolStats();
poolStats.setCorePoolSize(executor.getCorePoolSize());
poolStats.setMaximumPoolSize(executor.getMaximumPoolSize());
poolStats.setPoolSize(executor.getPoolSize());
poolStats.setActiveCount(executor.getActiveCount());
poolStats.setLargestPoolSize(executor.getLargestPoolSize());
poolStats.setQueueType(executor.getQueueType());
poolStats.setQueueCapacity(executor.getQueueCapacity());
poolStats.setQueueSize(executor.getQueueSize());
poolStats.setQueueRemainingCapacity(executor.getQueueRemainingCapacity());
poolStats.setTaskCount(executor.getTaskCount());
poolStats.setCompletedTaskCount(executor.getCompletedTaskCount());
poolStats.setWaitTaskCount(executor.getQueueSize());
poolStats.setRejectHandlerName(executor.getRejectHandlerType());
return poolStats;
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -44,9 +44,7 @@ private AlarmCounter() { }

public static void init(String threadPoolName, String notifyItemType) {
String key = buildKey(threadPoolName, notifyItemType);
val alarmInfo = AlarmInfo.builder()
.notifyItem(NotifyItemEnum.of(notifyItemType))
.build();
val alarmInfo = new AlarmInfo().setNotifyItem(NotifyItemEnum.of(notifyItemType));
ALARM_INFO_CACHE.putIfAbsent(key, alarmInfo);
}

Expand Down

0 comments on commit 2758fdb

Please sign in to comment.