This is an automated email from the ASF dual-hosted git repository.
mikexue pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/eventmesh.git
The following commit(s) were added to refs/heads/master by this push:
new e1e9acab0 [ISSUE #3835]Add final and @Nonnull[EventMeshThreadFactory]
e1e9acab0 is described below
commit e1e9acab09291b2eb10f1a88ee28dd0103bf26a6
Author: Harshitha Sudhakar
<[email protected]>
AuthorDate: Sat May 6 14:19:02 2023 +0530
[ISSUE #3835]Add final and @Nonnull[EventMeshThreadFactory]
---
.../java/org/apache/eventmesh/common/EventMeshThreadFactory.java | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git
a/eventmesh-common/src/main/java/org/apache/eventmesh/common/EventMeshThreadFactory.java
b/eventmesh-common/src/main/java/org/apache/eventmesh/common/EventMeshThreadFactory.java
index f4a647338..0442ef128 100644
---
a/eventmesh-common/src/main/java/org/apache/eventmesh/common/EventMeshThreadFactory.java
+++
b/eventmesh-common/src/main/java/org/apache/eventmesh/common/EventMeshThreadFactory.java
@@ -20,6 +20,8 @@ package org.apache.eventmesh.common;
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.atomic.AtomicInteger;
+import javax.annotation.Nonnull;
+
import lombok.Getter;
public class EventMeshThreadFactory implements ThreadFactory {
@@ -28,7 +30,7 @@ public class EventMeshThreadFactory implements ThreadFactory {
private final String threadNamePrefix;
private final AtomicInteger threadIndex;
private final boolean daemon;
- private Integer priority;
+ private final Integer priority;
public EventMeshThreadFactory(final String threadNamePrefix, final
AtomicInteger threadIndex, final boolean daemon,
final Integer priority) {
@@ -62,7 +64,7 @@ public class EventMeshThreadFactory implements ThreadFactory {
* @return constructed thread, or {@code null} if the request to create a
thread is rejected
*/
@Override
- public Thread newThread(final Runnable runnable) {
+ public Thread newThread(@Nonnull final Runnable runnable) {
StringBuilder threadName = new StringBuilder(threadNamePrefix);
if (null != threadIndex) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
