This is an automated email from the ASF dual-hosted git repository.
nizhikov pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git
The following commit(s) were added to refs/heads/master by this push:
new 1e875eea5ec [MINOR] Move IgniteThread to commons (#12278)
1e875eea5ec is described below
commit 1e875eea5ece4d9f024b740f526c0d4e37b54a96
Author: Nikolay <[email protected]>
AuthorDate: Tue Aug 19 17:12:01 2025 +0300
[MINOR] Move IgniteThread to commons (#12278)
---
.../ignite/internal/managers/communication/GridIoPolicy.java | 0
.../src/main/java/org/apache/ignite/thread/IgniteThread.java | 10 ----------
.../index/sorted/DurableBackgroundCleanupIndexTreeTaskV2.java | 3 +--
.../internal/managers/discovery/GridDiscoveryManager.java | 6 +++---
.../processors/cache/GridCacheSharedTtlCleanupManager.java | 3 +--
.../ignite/internal/processors/cache/WalStateManager.java | 2 +-
.../processors/cache/binary/BinaryMetadataFileStore.java | 3 +--
.../processors/cache/persistence/checkpoint/Checkpointer.java | 3 +--
.../cache/persistence/file/FilePageStoreManager.java | 3 +--
.../cache/persistence/wal/FileWriteAheadLogManager.java | 9 ++++-----
.../persistence/wal/filehandle/FileHandleManagerImpl.java | 5 ++---
.../processors/cache/store/GridCacheWriteBehindStore.java | 3 +--
.../processors/continuous/GridContinuousProcessor.java | 2 +-
.../internal/processors/datastreamer/DataStreamProcessor.java | 3 +--
.../processors/odbc/jdbc/JdbcRequestHandlerWorker.java | 4 ++--
.../processors/odbc/odbc/OdbcRequestHandlerWorker.java | 4 ++--
.../performancestatistics/FilePerformanceStatisticsWriter.java | 3 +--
.../performancestatistics/PerformanceStatisticsProcessor.java | 3 +--
.../ignite/internal/processors/query/SqlClientContext.java | 2 +-
.../internal/processors/query/running/HeavyQueriesTracker.java | 2 +-
.../processors/query/schema/SchemaOperationWorker.java | 4 ++--
.../internal/processors/timeout/GridTimeoutProcessor.java | 3 +--
.../main/java/org/apache/ignite/internal/util/IgniteUtils.java | 10 ++++++++++
.../org/apache/ignite/internal/util/nio/GridNioServer.java | 4 ++--
.../apache/ignite/failure/SystemWorkersTerminationTest.java | 2 +-
.../metastorage/persistence/DmsDataWriterWorkerTest.java | 3 ++-
26 files changed, 44 insertions(+), 55 deletions(-)
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoPolicy.java
b/modules/commons/src/main/java/org/apache/ignite/internal/managers/communication/GridIoPolicy.java
similarity index 100%
rename from
modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoPolicy.java
rename to
modules/commons/src/main/java/org/apache/ignite/internal/managers/communication/GridIoPolicy.java
diff --git
a/modules/core/src/main/java/org/apache/ignite/thread/IgniteThread.java
b/modules/commons/src/main/java/org/apache/ignite/thread/IgniteThread.java
similarity index 96%
rename from
modules/core/src/main/java/org/apache/ignite/thread/IgniteThread.java
rename to
modules/commons/src/main/java/org/apache/ignite/thread/IgniteThread.java
index 6c65e69d2df..3e5104ae55c 100644
--- a/modules/core/src/main/java/org/apache/ignite/thread/IgniteThread.java
+++ b/modules/commons/src/main/java/org/apache/ignite/thread/IgniteThread.java
@@ -21,7 +21,6 @@ import java.util.concurrent.atomic.AtomicLong;
import org.apache.ignite.internal.managers.communication.GridIoPolicy;
import org.apache.ignite.internal.util.typedef.internal.A;
import org.apache.ignite.internal.util.typedef.internal.S;
-import org.apache.ignite.internal.util.worker.GridWorker;
/**
* This class adds some necessary plumbing on top of the {@link Thread} class.
@@ -59,15 +58,6 @@ public class IgniteThread extends Thread {
/** */
private boolean forbiddenToRequestBinaryMetadata;
- /**
- * Creates thread with given worker.
- *
- * @param worker Runnable to create thread with.
- */
- public IgniteThread(GridWorker worker) {
- this(worker.igniteInstanceName(), worker.name(), worker,
GRP_IDX_UNASSIGNED, -1, GridIoPolicy.UNDEFINED);
- }
-
/**
* Creates grid thread with given name for a given Ignite instance.
*
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/cache/query/index/sorted/DurableBackgroundCleanupIndexTreeTaskV2.java
b/modules/core/src/main/java/org/apache/ignite/internal/cache/query/index/sorted/DurableBackgroundCleanupIndexTreeTaskV2.java
index a4aa1528cde..f5f2b3771c4 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/cache/query/index/sorted/DurableBackgroundCleanupIndexTreeTaskV2.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/cache/query/index/sorted/DurableBackgroundCleanupIndexTreeTaskV2.java
@@ -52,7 +52,6 @@ import org.apache.ignite.internal.util.typedef.internal.CU;
import org.apache.ignite.internal.util.typedef.internal.S;
import org.apache.ignite.internal.util.typedef.internal.U;
import org.apache.ignite.internal.util.worker.GridWorker;
-import org.apache.ignite.thread.IgniteThread;
import org.jetbrains.annotations.Nullable;
import static java.util.Collections.emptyList;
@@ -259,7 +258,7 @@ public class DurableBackgroundCleanupIndexTreeTaskV2
extends IgniteDataTransferO
}
};
- new IgniteThread(w).start();
+ U.newThread(w).start();
this.worker = w;
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManager.java
b/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManager.java
index d484a6222f1..7334cfc16c9 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManager.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManager.java
@@ -1078,7 +1078,7 @@ public class GridDiscoveryManager extends
GridManagerAdapter<DiscoverySpi> {
if (hasRslvrs && segChkFreq > 0) {
segChkWrk = new SegmentCheckWorker();
- segChkThread = new IgniteThread(segChkWrk);
+ segChkThread = U.newThread(segChkWrk);
segChkThread.setUncaughtExceptionHandler(new
OomExceptionHandler(ctx));
@@ -1090,7 +1090,7 @@ public class GridDiscoveryManager extends
GridManagerAdapter<DiscoverySpi> {
checkAttributes(discoCache().remoteNodes());
// Start discovery worker.
- new IgniteThread(discoWrk).start();
+ U.newThread(discoWrk).start();
if (log.isDebugEnabled())
log.debug(startInfo());
@@ -2785,7 +2785,7 @@ public class GridDiscoveryManager extends
GridManagerAdapter<DiscoverySpi> {
/** {@inheritDoc} */
public DiscoveryMessageNotifierThread(GridWorker worker) {
- super(worker);
+ super(worker.igniteInstanceName(), worker.name(), worker);
this.worker = worker;
}
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheSharedTtlCleanupManager.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheSharedTtlCleanupManager.java
index dc3aa396e8a..b3cf6b9e56e 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheSharedTtlCleanupManager.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheSharedTtlCleanupManager.java
@@ -31,7 +31,6 @@ import
org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion;
import org.apache.ignite.internal.util.typedef.X;
import org.apache.ignite.internal.util.typedef.internal.U;
import org.apache.ignite.internal.util.worker.GridWorker;
-import org.apache.ignite.thread.IgniteThread;
import static org.apache.ignite.failure.FailureType.CRITICAL_ERROR;
import static org.apache.ignite.failure.FailureType.SYSTEM_WORKER_TERMINATION;
@@ -112,7 +111,7 @@ public class GridCacheSharedTtlCleanupManager extends
GridCacheSharedManagerAdap
cleanupWorker = new CleanupWorker();
- new IgniteThread(cleanupWorker).start();
+ U.newThread(cleanupWorker).start();
}
finally {
lock.unlock();
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/WalStateManager.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/WalStateManager.java
index 525b4dd0d8f..6a64035b7c9 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/WalStateManager.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/WalStateManager.java
@@ -601,7 +601,7 @@ public class WalStateManager extends
GridCacheSharedManagerAdapter {
// not-yet-flushed dirty pages have been
logged.
WalStateChangeWorker worker = new
WalStateChangeWorker(msg, cpFut);
- IgniteThread thread = new
IgniteThread(worker);
+ IgniteThread thread = U.newThread(worker);
thread.setUncaughtExceptionHandler(new
OomExceptionHandler(
cctx.kernalContext()));
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/BinaryMetadataFileStore.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/BinaryMetadataFileStore.java
index 4546b4d53c6..5819bdc104c 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/BinaryMetadataFileStore.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/BinaryMetadataFileStore.java
@@ -46,7 +46,6 @@ import org.apache.ignite.internal.util.typedef.internal.CU;
import org.apache.ignite.internal.util.typedef.internal.S;
import org.apache.ignite.internal.util.typedef.internal.U;
import org.apache.ignite.internal.util.worker.GridWorker;
-import org.apache.ignite.thread.IgniteThread;
import static java.nio.file.StandardCopyOption.ATOMIC_MOVE;
import static java.nio.file.StandardCopyOption.REPLACE_EXISTING;
@@ -125,7 +124,7 @@ class BinaryMetadataFileStore {
writer = new BinaryMetadataAsyncWriter();
- new IgniteThread(writer).start();
+ U.newThread(writer).start();
}
/**
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/checkpoint/Checkpointer.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/checkpoint/Checkpointer.java
index 46f3e981407..e371ea0ca52 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/checkpoint/Checkpointer.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/checkpoint/Checkpointer.java
@@ -67,7 +67,6 @@ import
org.apache.ignite.internal.util.worker.WorkProgressDispatcher;
import org.apache.ignite.internal.worker.WorkersRegistry;
import org.apache.ignite.lang.IgniteBiTuple;
import org.apache.ignite.lang.IgniteInClosure;
-import org.apache.ignite.thread.IgniteThread;
import org.apache.ignite.thread.IgniteThreadPoolExecutor;
import org.jetbrains.annotations.Nullable;
import org.jsr166.ConcurrentLinkedHashMap;
@@ -1025,7 +1024,7 @@ public class Checkpointer extends GridWorker {
assert runner() == null : "Checkpointer is running.";
- new IgniteThread(this).start();
+ U.newThread(this).start();
}
/**
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/file/FilePageStoreManager.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/file/FilePageStoreManager.java
index 97115e46ba3..4866664f2ec 100755
---
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/file/FilePageStoreManager.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/file/FilePageStoreManager.java
@@ -79,7 +79,6 @@ import org.apache.ignite.internal.util.worker.GridWorker;
import org.apache.ignite.lang.IgniteOutClosure;
import org.apache.ignite.maintenance.MaintenanceRegistry;
import org.apache.ignite.maintenance.MaintenanceTask;
-import org.apache.ignite.thread.IgniteThread;
import org.jetbrains.annotations.Nullable;
import static java.nio.file.Files.delete;
@@ -963,7 +962,7 @@ public class FilePageStoreManager extends
GridCacheSharedManagerAdapter implemen
workers.add(worker);
- Thread asyncTask = new IgniteThread(worker);
+ Thread asyncTask = U.newThread(worker);
asyncTask.start();
}
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/wal/FileWriteAheadLogManager.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/wal/FileWriteAheadLogManager.java
index 6941ddc4142..ec823044eef 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/wal/FileWriteAheadLogManager.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/wal/FileWriteAheadLogManager.java
@@ -128,7 +128,6 @@ import org.apache.ignite.lang.IgniteBiTuple;
import org.apache.ignite.lang.IgniteInClosure;
import org.apache.ignite.lang.IgnitePredicate;
import org.apache.ignite.lang.IgniteUuid;
-import org.apache.ignite.thread.IgniteThread;
import org.jetbrains.annotations.Nullable;
import static java.lang.String.format;
@@ -2180,7 +2179,7 @@ public class FileWriteAheadLogManager extends
GridCacheSharedManagerAdapter impl
isCancelled.set(false);
- new IgniteThread(archiver).start();
+ U.newThread(archiver).start();
}
/**
@@ -2320,7 +2319,7 @@ public class FileWriteAheadLogManager extends
GridCacheSharedManagerAdapter impl
isCancelled.set(false);
- new IgniteThread(this).start();
+ U.newThread(this).start();
}
/**
@@ -2684,7 +2683,7 @@ public class FileWriteAheadLogManager extends
GridCacheSharedManagerAdapter impl
isCancelled.set(false);
- new IgniteThread(this).start();
+ U.newThread(this).start();
}
}
@@ -3383,7 +3382,7 @@ public class FileWriteAheadLogManager extends
GridCacheSharedManagerAdapter impl
isCancelled.set(false);
- new IgniteThread(this).start();
+ U.newThread(this).start();
}
}
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/wal/filehandle/FileHandleManagerImpl.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/wal/filehandle/FileHandleManagerImpl.java
index 6b08531a233..64b65e753f4 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/wal/filehandle/FileHandleManagerImpl.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/wal/filehandle/FileHandleManagerImpl.java
@@ -40,7 +40,6 @@ import
org.apache.ignite.internal.processors.cache.persistence.wal.io.SegmentIO;
import
org.apache.ignite.internal.processors.cache.persistence.wal.serializer.RecordSerializer;
import org.apache.ignite.internal.util.typedef.internal.U;
import org.apache.ignite.internal.util.worker.GridWorker;
-import org.apache.ignite.thread.IgniteThread;
import static java.lang.Long.MAX_VALUE;
import static
org.apache.ignite.IgniteSystemProperties.IGNITE_WAL_SEGMENT_SYNC_TIMEOUT;
@@ -583,7 +582,7 @@ public class FileHandleManagerImpl implements
FileHandleManager {
isCancelled.set(false);
- new IgniteThread(this).start();
+ U.newThread(this).start();
}
}
@@ -640,7 +639,7 @@ public class FileHandleManagerImpl implements
FileHandleManager {
isCancelled.set(false);
- new IgniteThread(walSegmentSyncWorker).start();
+ U.newThread(walSegmentSyncWorker).start();
}
}
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/store/GridCacheWriteBehindStore.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/store/GridCacheWriteBehindStore.java
index 6a7ca94f4f1..53fe107a8fa 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/store/GridCacheWriteBehindStore.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/store/GridCacheWriteBehindStore.java
@@ -49,7 +49,6 @@ import org.apache.ignite.internal.util.worker.GridWorker;
import org.apache.ignite.lang.IgniteBiInClosure;
import org.apache.ignite.lang.IgniteBiTuple;
import org.apache.ignite.lifecycle.LifecycleAware;
-import org.apache.ignite.thread.IgniteThread;
import org.apache.ignite.util.deque.FastSizeDeque;
import org.jetbrains.annotations.Nullable;
import org.jsr166.ConcurrentLinkedHashMap;
@@ -996,7 +995,7 @@ public class GridCacheWriteBehindStore<K, V> implements
CacheStore<K, V>, Lifecy
/** Start flusher thread */
protected void start() {
- thread = new IgniteThread(this);
+ thread = U.newThread(this);
thread.start();
}
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousProcessor.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousProcessor.java
index 047ba629cff..df98fc299d4 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousProcessor.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousProcessor.java
@@ -1770,7 +1770,7 @@ public class GridContinuousProcessor extends
GridProcessorAdapter {
log.debug("Register handler: [nodeId=" + nodeId + ",
routineId=" + routineId + ", info=" + info + ']');
if (interval > 0) {
- IgniteThread checker = new IgniteThread(new
GridWorker(ctx.igniteInstanceName(), "continuous-buffer-checker", log) {
+ IgniteThread checker = U.newThread(new
GridWorker(ctx.igniteInstanceName(), "continuous-buffer-checker", log) {
@Override protected void body() {
long interval0 = interval;
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamProcessor.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamProcessor.java
index 2ba2dbddf6e..65f225b22a9 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamProcessor.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamProcessor.java
@@ -47,7 +47,6 @@ import org.apache.ignite.lang.IgniteFuture;
import org.apache.ignite.lang.IgniteInClosure;
import org.apache.ignite.marshaller.Marshaller;
import org.apache.ignite.stream.StreamReceiver;
-import org.apache.ignite.thread.IgniteThread;
import org.apache.ignite.thread.OomExceptionHandler;
import org.jetbrains.annotations.Nullable;
@@ -100,7 +99,7 @@ public class DataStreamProcessor<K, V> extends
GridProcessorAdapter {
marshErrBytes = U.marshal(marsh, new IgniteCheckedException("Failed to
marshal response error, " +
"see node log for details."));
- flusher = new IgniteThread(new GridWorker(ctx.igniteInstanceName(),
"grid-data-loader-flusher", log) {
+ flusher = U.newThread(new GridWorker(ctx.igniteInstanceName(),
"grid-data-loader-flusher", log) {
@Override protected void body() throws InterruptedException {
while (!isCancelled()) {
DataStreamerImpl<K, V> ldr = flushQ.take();
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/processors/odbc/jdbc/JdbcRequestHandlerWorker.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/odbc/jdbc/JdbcRequestHandlerWorker.java
index 06fda201a2d..965db4f9810 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/processors/odbc/jdbc/JdbcRequestHandlerWorker.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/processors/odbc/jdbc/JdbcRequestHandlerWorker.java
@@ -27,8 +27,8 @@ import
org.apache.ignite.internal.processors.odbc.ClientListenerResponse;
import org.apache.ignite.internal.util.future.GridFutureAdapter;
import org.apache.ignite.internal.util.typedef.T2;
import org.apache.ignite.internal.util.typedef.internal.A;
+import org.apache.ignite.internal.util.typedef.internal.U;
import org.apache.ignite.internal.util.worker.GridWorker;
-import org.apache.ignite.thread.IgniteThread;
import org.jetbrains.annotations.Nullable;
/**
@@ -74,7 +74,7 @@ class JdbcRequestHandlerWorker extends GridWorker {
* Start this worker.
*/
void start() {
- new IgniteThread(this).start();
+ U.newThread(this).start();
}
/** {@inheritDoc} */
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/processors/odbc/odbc/OdbcRequestHandlerWorker.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/odbc/odbc/OdbcRequestHandlerWorker.java
index 4a9b5080ea3..26c2b865c0d 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/processors/odbc/odbc/OdbcRequestHandlerWorker.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/processors/odbc/odbc/OdbcRequestHandlerWorker.java
@@ -27,8 +27,8 @@ import
org.apache.ignite.internal.processors.odbc.ClientListenerResponse;
import org.apache.ignite.internal.util.future.GridFutureAdapter;
import org.apache.ignite.internal.util.typedef.T2;
import org.apache.ignite.internal.util.typedef.internal.A;
+import org.apache.ignite.internal.util.typedef.internal.U;
import org.apache.ignite.internal.util.worker.GridWorker;
-import org.apache.ignite.thread.IgniteThread;
import org.jetbrains.annotations.Nullable;
/**
@@ -74,7 +74,7 @@ class OdbcRequestHandlerWorker extends GridWorker {
* Start this worker.
*/
void start() {
- new IgniteThread(this).start();
+ U.newThread(this).start();
}
/** {@inheritDoc} */
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/processors/performancestatistics/FilePerformanceStatisticsWriter.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/performancestatistics/FilePerformanceStatisticsWriter.java
index 774b14cacf7..36f48e78546 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/processors/performancestatistics/FilePerformanceStatisticsWriter.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/processors/performancestatistics/FilePerformanceStatisticsWriter.java
@@ -42,7 +42,6 @@ import org.apache.ignite.internal.util.GridIntList;
import org.apache.ignite.internal.util.typedef.internal.U;
import org.apache.ignite.internal.util.worker.GridWorker;
import org.apache.ignite.lang.IgniteUuid;
-import org.apache.ignite.thread.IgniteThread;
import static
org.apache.ignite.IgniteSystemProperties.IGNITE_PERF_STAT_BUFFER_SIZE;
import static
org.apache.ignite.IgniteSystemProperties.IGNITE_PERF_STAT_FILE_MAX_SIZE;
@@ -163,7 +162,7 @@ public class FilePerformanceStatisticsWriter {
public synchronized void start() {
assert !started;
- new IgniteThread(fileWriter).start();
+ U.newThread(fileWriter).start();
started = true;
}
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/processors/performancestatistics/PerformanceStatisticsProcessor.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/performancestatistics/PerformanceStatisticsProcessor.java
index c239320cad6..4fcdbc9b560 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/processors/performancestatistics/PerformanceStatisticsProcessor.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/processors/performancestatistics/PerformanceStatisticsProcessor.java
@@ -42,7 +42,6 @@ import org.apache.ignite.internal.util.typedef.internal.A;
import org.apache.ignite.internal.util.typedef.internal.U;
import org.apache.ignite.lang.IgniteFuture;
import org.apache.ignite.lang.IgniteUuid;
-import org.apache.ignite.thread.IgniteThread;
import org.jetbrains.annotations.Nullable;
import static
org.apache.ignite.internal.processors.metastorage.DistributedMetaStorage.IGNITE_INTERNAL_KEY_PREFIX;
@@ -373,7 +372,7 @@ public class PerformanceStatisticsProcessor extends
GridProcessorAdapter {
sysViewWriter = new SystemViewFileWriter(ctx);
writer.start();
- new IgniteThread(sysViewWriter).start();
+ U.newThread(sysViewWriter).start();
}
lsnrs.forEach(PerformanceStatisticsStateListener::onStarted);
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/processors/query/SqlClientContext.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/query/SqlClientContext.java
index 3d8a33dfabc..0e45c6177bc 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/processors/query/SqlClientContext.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/processors/query/SqlClientContext.java
@@ -195,7 +195,7 @@ public class SqlClientContext implements AutoCloseable {
this.totalProcessedOrderedReqs = 0;
if (ordered) {
- orderedBatchThread = new
IgniteThread(orderedBatchWorkerFactory.create());
+ orderedBatchThread =
U.newThread(orderedBatchWorkerFactory.create());
orderedBatchThread.start();
}
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/processors/query/running/HeavyQueriesTracker.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/query/running/HeavyQueriesTracker.java
index 69b8e635198..72ca9731ecf 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/processors/query/running/HeavyQueriesTracker.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/processors/query/running/HeavyQueriesTracker.java
@@ -109,7 +109,7 @@ public final class HeavyQueriesTracker {
timeout =
ctx.config().getSqlConfiguration().getLongQueryWarningTimeout();
- IgniteThread thread = new IgniteThread(checkWorker);
+ IgniteThread thread = U.newThread(checkWorker);
thread.setDaemon(true);
thread.start();
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/processors/query/schema/SchemaOperationWorker.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/query/schema/SchemaOperationWorker.java
index 6df7dd7ebc0..1967bdebb35 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/processors/query/schema/SchemaOperationWorker.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/processors/query/schema/SchemaOperationWorker.java
@@ -28,11 +28,11 @@ import
org.apache.ignite.internal.processors.query.QueryUtils;
import
org.apache.ignite.internal.processors.query.schema.operation.SchemaAbstractOperation;
import
org.apache.ignite.internal.processors.query.schema.operation.SchemaAddQueryEntityOperation;
import org.apache.ignite.internal.util.future.GridFutureAdapter;
+import org.apache.ignite.internal.util.typedef.internal.U;
import org.apache.ignite.internal.util.worker.GridWorker;
import org.apache.ignite.internal.worker.WorkersRegistry;
import org.apache.ignite.lang.IgniteInClosure;
import org.apache.ignite.lang.IgniteUuid;
-import org.apache.ignite.thread.IgniteThread;
import org.jetbrains.annotations.Nullable;
/**
@@ -128,7 +128,7 @@ public class SchemaOperationWorker extends GridWorker {
public SchemaOperationWorker start() {
if (startGuard.compareAndSet(false, true)) {
if (!fut.isDone())
- new IgniteThread(this).start();
+ U.newThread(this).start();
}
return this;
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/processors/timeout/GridTimeoutProcessor.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/timeout/GridTimeoutProcessor.java
index ac3333026a5..03c72d413ad 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/processors/timeout/GridTimeoutProcessor.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/processors/timeout/GridTimeoutProcessor.java
@@ -35,7 +35,6 @@ import org.apache.ignite.internal.util.worker.GridWorker;
import org.apache.ignite.lang.IgniteBiInClosure;
import org.apache.ignite.lang.IgniteInClosure;
import org.apache.ignite.lang.IgniteUuid;
-import org.apache.ignite.thread.IgniteThread;
import static org.apache.ignite.failure.FailureType.CRITICAL_ERROR;
import static org.apache.ignite.failure.FailureType.SYSTEM_WORKER_TERMINATION;
@@ -81,7 +80,7 @@ public class GridTimeoutProcessor extends
GridProcessorAdapter {
/** {@inheritDoc} */
@Override public void start() {
- new IgniteThread(timeoutWorker).start();
+ U.newThread(timeoutWorker).start();
if (log.isDebugEnabled())
log.debug("Timeout processor started.");
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteUtils.java
b/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteUtils.java
index e8c5a63c337..de3302a80bf 100755
---
a/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteUtils.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteUtils.java
@@ -237,6 +237,7 @@ import org.apache.ignite.spi.IgniteSpiException;
import org.apache.ignite.spi.discovery.DiscoverySpi;
import org.apache.ignite.spi.discovery.DiscoverySpiOrderSupport;
import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi;
+import org.apache.ignite.thread.IgniteThread;
import org.apache.ignite.thread.IgniteThreadFactory;
import org.apache.ignite.transactions.TransactionDeadlockException;
import org.apache.ignite.transactions.TransactionHeuristicException;
@@ -9034,6 +9035,15 @@ public abstract class IgniteUtils extends CommonUtils {
return null;
}
+ /**
+ * Creates thread with given worker.
+ *
+ * @param worker Runnable to create thread with.
+ */
+ public static IgniteThread newThread(GridWorker worker) {
+ return new IgniteThread(worker.igniteInstanceName(), worker.name(),
worker);
+ }
+
/** */
@SuppressWarnings("PublicInnerClass")
public static class TestBinaryContext extends BinaryContext {
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioServer.java
b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioServer.java
index b8c913bffef..00e29d0ccf5 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioServer.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioServer.java
@@ -416,7 +416,7 @@ public class GridNioServer<T> {
clientWorkers.add(worker);
- clientThreads[i] = new IgniteThread(worker);
+ clientThreads[i] = U.newThread(worker);
clientThreads[i].setDaemon(daemon);
}
@@ -504,7 +504,7 @@ public class GridNioServer<T> {
filterChain.start();
if (acceptWorker != null)
- new IgniteThread(acceptWorker).start();
+ U.newThread(acceptWorker).start();
for (IgniteThread thread : clientThreads)
thread.start();
diff --git
a/modules/core/src/test/java/org/apache/ignite/failure/SystemWorkersTerminationTest.java
b/modules/core/src/test/java/org/apache/ignite/failure/SystemWorkersTerminationTest.java
index 671fea28d4f..d0dde050b38 100644
---
a/modules/core/src/test/java/org/apache/ignite/failure/SystemWorkersTerminationTest.java
+++
b/modules/core/src/test/java/org/apache/ignite/failure/SystemWorkersTerminationTest.java
@@ -90,7 +90,7 @@ public class SystemWorkersTerminationTest extends
GridCommonAbstractTest {
}
};
- IgniteThread thread = new IgniteThread(worker);
+ IgniteThread thread = U.newThread(worker);
failureHndThreadName = null;
diff --git
a/modules/core/src/test/java/org/apache/ignite/internal/processors/metastorage/persistence/DmsDataWriterWorkerTest.java
b/modules/core/src/test/java/org/apache/ignite/internal/processors/metastorage/persistence/DmsDataWriterWorkerTest.java
index c22aa206541..6f0ba81c90a 100644
---
a/modules/core/src/test/java/org/apache/ignite/internal/processors/metastorage/persistence/DmsDataWriterWorkerTest.java
+++
b/modules/core/src/test/java/org/apache/ignite/internal/processors/metastorage/persistence/DmsDataWriterWorkerTest.java
@@ -23,6 +23,7 @@ import java.util.concurrent.RunnableFuture;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.atomic.AtomicReference;
import org.apache.ignite.IgniteCheckedException;
+import org.apache.ignite.internal.util.typedef.internal.U;
import org.apache.ignite.testframework.GridTestUtils;
import org.apache.ignite.testframework.junits.common.GridCommonAbstractTest;
import org.apache.ignite.thread.IgniteThread;
@@ -352,7 +353,7 @@ public class DmsDataWriterWorkerTest extends
GridCommonAbstractTest {
/** */
private IgniteThread startWorker() throws InterruptedException {
- IgniteThread workerThread = new IgniteThread(worker);
+ IgniteThread workerThread = U.newThread(worker);
workerThread.start();
