Skip to content

Commit 33d3217

Browse files
rm-gh-8Paul Hohensee
authored andcommitted
8370905: Update vm.defmeth tests to use virtual threads
Backport-of: 153c567
1 parent af16234 commit 33d3217

1 file changed

Lines changed: 13 additions & 10 deletions

File tree

test/hotspot/jtreg/vmTestbase/vm/runtime/defmeth/StressTest.java

Lines changed: 13 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -44,6 +44,7 @@
4444
import java.util.List;
4545
import java.util.Random;
4646

47+
import jdk.test.lib.thread.TestThreadFactory;
4748
import nsk.share.TestFailure;
4849
import nsk.share.test.StressOptions;
4950
import nsk.share.test.Stresser;
@@ -82,16 +83,18 @@ public class StressTest implements Runnable {
8283
@Option(name="ignoreTestFailures", default_value="false", description="ignore failures of the executed tests")
8384
private boolean ignoreTestFailures;
8485

85-
class Worker extends Thread {
86+
class Worker implements Runnable {
8687
private final Random rand;
8788

8889
private volatile DefMethTest failedTest;
8990
private Throwable reason;
9091
private volatile long executedTests = 0;
9192

92-
public Worker(String id, long seed) {
93-
setName(id);
94-
this.rand = new Random(seed);
93+
private final Thread thread;
94+
95+
Worker(String id, long seed) {
96+
this.rand = new Random(seed);
97+
this.thread = TestThreadFactory.newThread(this, id);
9598
}
9699

97100
@Override
@@ -247,28 +250,28 @@ private void startWorkers() {
247250
}
248251

249252
for (Worker worker : workers) {
250-
worker.start();
253+
worker.thread.start();
251254
}
252255
}
253256

254257
private void interruptWorkers() {
255258
for (Worker worker : workers) {
256-
worker.interrupt();
259+
worker.thread.interrupt();
257260
}
258261
}
259262

260263
private void joinWorkers() {
261264
boolean isFailed = false;
262265

263266
for (Worker worker : workers) {
264-
while (worker.isAlive()) {
267+
while (worker.thread.isAlive()) {
265268
try {
266-
worker.join();
269+
worker.thread.join();
267270
} catch (InterruptedException e) {}
268271
}
269272

270273
System.out.printf("%s: %s (executed: %d)\n",
271-
worker.getName(),
274+
worker.thread.getName(),
272275
worker.isFailed() ? "FAILED: " + worker.getFailedTest() : "PASSED",
273276
worker.getExecutedTests());
274277

@@ -288,7 +291,7 @@ private void joinWorkers() {
288291

289292
private boolean workersAlive() {
290293
for (Worker worker : workers) {
291-
if (!worker.isAlive()) {
294+
if (!worker.thread.isAlive()) {
292295
return false;
293296
}
294297
}

0 commit comments

Comments
 (0)