stef_buwalda/pism
1
0
Fork 0
mirror of https://github.com/2OOP/pism.git synced 2026-02-04 02:44:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

readded threads argument

Browse Source
This commit is contained in:
ramollia
2026-01-23 19:14:46 +01:00
parent 11eda3c8b5
commit 97276c7e80
2 changed files with 20 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
game/src/main/java/org/toop/game/players/ai/mcts/MCTSAI3.java
View File

@@ -9,16 +9,21 @@ import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
public class MCTSAI3 extends MCTSAI { public class MCTSAI3 extends MCTSAI {
private static final int THREADS = 8; private final int threads;
private final ExecutorService threadPool;
private static final ExecutorService threadPool = Executors.newFixedThreadPool(THREADS); public MCTSAI3(int milliseconds, int threads) {
public MCTSAI3(int milliseconds) {
super(milliseconds); super(milliseconds);
this.threads = threads;
this.threadPool = Executors.newFixedThreadPool(threads);
} }
public MCTSAI3(MCTSAI3 other) { public MCTSAI3(MCTSAI3 other) {
super(other); super(other);
this.threads = other.threads;
this.threadPool = other.threadPool;
} }
@Override @Override
@@ -32,9 +37,9 @@ public class MCTSAI3 extends MCTSAI {
final long endTime = System.nanoTime() + milliseconds * 1_000_000L; final long endTime = System.nanoTime() + milliseconds * 1_000_000L;
final CountDownLatch latch = new CountDownLatch(THREADS); final CountDownLatch latch = new CountDownLatch(threads);
for (int i = 0; i < THREADS; i++) { for (int i = 0; i < threads; i++) {
threadPool.submit(() -> { threadPool.submit(() -> {
try { try {
iterate(root, endTime); iterate(root, endTime);

17
game/src/main/java/org/toop/game/players/ai/mcts/MCTSAI4.java
View File

@@ -9,22 +9,23 @@ import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
public class MCTSAI4 extends MCTSAI { public class MCTSAI4 extends MCTSAI {
private static final int THREADS = 8; private final int threads;
private final ExecutorService threadPool;
private static final ExecutorService threadPool = Executors.newFixedThreadPool(THREADS);
private Node root; private Node root;
public MCTSAI4(int milliseconds) { public MCTSAI4(int milliseconds, int threads) {
super(milliseconds); super(milliseconds);
this.root = null; this.threads = threads;
this.threadPool = Executors.newFixedThreadPool(threads);
} }
public MCTSAI4(MCTSAI4 other) { public MCTSAI4(MCTSAI4 other) {
super(other); super(other);
this.root = other.root; this.threads = other.threads;
this.threadPool = other.threadPool;
} }
@Override @Override
@@ -38,9 +39,9 @@ public class MCTSAI4 extends MCTSAI {
final long endTime = System.nanoTime() + milliseconds * 1_000_000L; final long endTime = System.nanoTime() + milliseconds * 1_000_000L;
final CountDownLatch latch = new CountDownLatch(THREADS); final CountDownLatch latch = new CountDownLatch(threads);
for (int i = 0; i < THREADS; i++) { for (int i = 0; i < threads; i++) {
threadPool.submit(() -> { threadPool.submit(() -> {
try { try {
iterate(root, endTime); iterate(root, endTime);