Skip to content

Commit

Permalink
Revert "Optimise the strategy we use to reset the classloader in the …
Browse files Browse the repository at this point in the history
…Common ForkJoin ThreadPool"

This reverts commit ae9a634.

Fixes quarkusio#19136

(cherry picked from commit b404d4b)
  • Loading branch information
stuartwdouglas authored and gsmet committed Aug 3, 2021
1 parent feafd47 commit af65575
Showing 1 changed file with 22 additions and 33 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -20,42 +20,31 @@ public class ForkJoinClassLoading {
* Really we should just not use the common pool at all.
*/
public static void setForkJoinClassLoader(ClassLoader classLoader) {
final ForkJoinPool commonPool = ForkJoinPool.commonPool();

final int activeThreadCount = commonPool.getActiveThreadCount();

//The following approach is rather heavy, but there's good chances that there are actually no active threads,
//so skip it in this case.
//Additionally, if we can skip this this will prevent us from actually forcing to start all threads in the pool.
if (activeThreadCount > 0) {
//TODO we could theoretically improve this by using the system property java.util.concurrent.ForkJoinPool.common.threadFactory
//and force the common pool to register created threads so that we can reach and reset them.
CountDownLatch allDone = new CountDownLatch(ForkJoinPool.getCommonPoolParallelism());
CountDownLatch taskRelease = new CountDownLatch(1);
for (int i = 0; i < ForkJoinPool.getCommonPoolParallelism(); ++i) {
commonPool.execute(new Runnable() {
@Override
public void run() {
Thread.currentThread().setContextClassLoader(classLoader);
allDone.countDown();
try {
taskRelease.await();
} catch (InterruptedException e) {
log.error("Failed to set fork join ClassLoader", e);
}
CountDownLatch allDone = new CountDownLatch(ForkJoinPool.getCommonPoolParallelism());
CountDownLatch taskRelease = new CountDownLatch(1);
for (int i = 0; i < ForkJoinPool.getCommonPoolParallelism(); ++i) {
ForkJoinPool.commonPool().execute(new Runnable() {
@Override
public void run() {
Thread.currentThread().setContextClassLoader(classLoader);
allDone.countDown();
try {
taskRelease.await();
} catch (InterruptedException e) {
log.error("Failed to set fork join ClassLoader", e);
}
});
}
try {
if (!allDone.await(1, TimeUnit.SECONDS)) {
log.error(
"Timed out trying to set fork join ClassLoader, this should never happen unless something has tied up a fork join thread before the app launched");
}
} catch (InterruptedException e) {
log.error("Failed to set fork join ClassLoader", e);
} finally {
taskRelease.countDown();
});
}
try {
if (!allDone.await(1, TimeUnit.SECONDS)) {
log.error(
"Timed out trying to set fork join ClassLoader, this should never happen unless something has tied up a fork join thread before the app launched");
}
} catch (InterruptedException e) {
log.error("Failed to set fork join ClassLoader", e);
} finally {
taskRelease.countDown();
}
}
}

0 comments on commit af65575

Please sign in to comment.