lee/heritrix3
1
0
Fork 0
mirror of https://github.com/internetarchive/heritrix3.git synced 2026-09-24 06:36:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

Avoid using Thread.interrupt as this freaks BDB-JE.

Browse Source
This commit is contained in:
Andrew Jackson
2019-08-11 22:03:55 +01:00
parent 45cd46e030
commit 7dab6ec275
1 changed files with 12 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
modules/src/test/java/org/archive/modules/fetcher/CookieStoreTest.java
+12 -9
View File
@@ -30,6 +30,7 @@ import java.util.List;
import java.util.Map;
import java.util.Random;
import java.util.UUID;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.logging.Logger;
import org.apache.commons.io.FileUtils;
@@ -301,12 +302,14 @@ public class CookieStoreTest extends TmpDirTestCase {
bdbCookieStore().clear();
basicCookieStore().clear();
final Random rand = new Random();
final AtomicBoolean keepRunning = new AtomicBoolean(true);
Runnable runnable = new Runnable() {
@Override
public void run() {
try {
while (!Thread.interrupted()) {
while (keepRunning.get()) {
BasicClientCookie cookie = new BasicClientCookie(UUID.randomUUID().toString(), UUID.randomUUID().toString());
cookie.setDomain("d" + rand.nextInt() + ".example.com");
bdbCookieStore().addCookie(cookie);
@@ -326,10 +329,9 @@ public class CookieStoreTest extends TmpDirTestCase {
}
Thread.sleep(5000);
for (int i = 0; i < threads.length; i++) {
threads[i].interrupt();
}
// Shutdown the threads:
keepRunning.set(false);
for (int i = 0; i < threads.length; i++) {
threads[i].join();
}
@@ -343,12 +345,14 @@ public class CookieStoreTest extends TmpDirTestCase {
bdbCookieStore().clear();
basicCookieStore().clear();
final Random rand = new Random();
final AtomicBoolean keepRunning = new AtomicBoolean(true);
Runnable runnable = new Runnable() {
@Override
public void run() {
try {
while (!Thread.interrupted()) {
while (keepRunning.get()) {
BasicClientCookie cookie = new BasicClientCookie(UUID.randomUUID().toString(), UUID.randomUUID().toString());
cookie.setDomain("d" + rand.nextInt(20) + ".example.com");
bdbCookieStore().addCookie(cookie);
@@ -369,9 +373,8 @@ public class CookieStoreTest extends TmpDirTestCase {
Thread.sleep(1000);
for (int i = 0; i < threads.length; i++) {
threads[i].interrupt();
}
// Shutdown the threads:
keepRunning.set(false);
for (int i = 0; i < threads.length; i++) {
threads[i].join();
}