我在我的应用程序的一部分中尝试保存/创建/更新数据库中的数据时出现以下错误。该应用程序正常工作一段时间后,可以说在部署后接近1-2小时,但在一段时间后开始在更新调用上发出此错误。我正在使用JPA EclipseLink实现。
注意:更新调用是使用可填充的future进行异步完成的。调用看起来像这样:
CompletableFuture.supplyAsync(() -> {
if (someBean != null) {
try {
someReturnVal = methodCall();
} catch (Exception e) {
log.info("Log with reason: "
+ e.getMessage());
}
}
return someReturnVal;
}).thenAccept(someReturnVal -> {
try {
SomeBean.saveToDB(someReturnVal);
} catch (AccessException e) {
log.info("log with reason: " + e.getMessage());
}
});
SaveToDB看起来像:
@Transactional
public void SaveToDB(SomeBean arg1) {
try {
em.persist(arg1);
em.flush();
}Catch{
....
}
堆栈跟踪中的错误消息:
java.lang.IllegalArgumentException: Unable to create EvictionPolicy instance of type org.apache.commons.pool2.impl.DefaultEvictionPolicy
at org.apache.commons.pool2.impl.BaseGenericObjectPool.setEvictionPolicyClassName(BaseGenericObjectPool.java:607)
at org.apache.commons.pool2.impl.GenericKeyedObjectPool.setConfig(GenericKeyedObjectPool.java:257)
at org.apache.commons.pool2.impl.GenericKeyedObjectPool.<init>(GenericKeyedObjectPool.java:111)
at com.**.cloud.runtime.kotyo.persistence.client.pool.GenericKeyedObjectPoolAdapter.<init>(GenericKeyedObjectPoolAdapter.java:25)
at com.**.cloud.runtime.kotyo.persistence.client.pool.managed.PoolableManagedConnectionFactoryAdapter.makeObject(PoolableManagedConnectionFactoryAdapter.java:86)
at org.apache.commons.pool2.impl.GenericObjectPool.create(GenericObjectPool.java:861)
at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:435)
at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:363)...
...
Caused by: java.lang.ClassNotFoundException: org/apache/commons/pool2/impl/DefaultEvictionPolicy
at java.lang.Class.forName0(Native Method)
at java.lang.Class.forNameFW(Class.java:362)
at java.lang.Class.forName(Class.java:355)
at org.apache.commons.pool2.impl.BaseGenericObjectPool.setEvictionPolicyClassName(BaseGenericObjectPool.java:598)
... 77 common frames omitted
我在这里发生了什么错误,我很无能为力。有人可以帮我这里。
我能够通过使用Executors创建自己的ThreadPoolExecutor来解决此问题,如下所示:
ThreadPoolExecutor executor = (ThreadPoolExecutor) Executors.newCachedThreadPool();
然后我将此执行程序传递给我的CompletableFuture调用:
CompletableFuture.supplyAsync(() -> { ....
return someReturnVal;
}, executor).thenAccept(someReturnVal -> {
....
});
这解决了我的问题。问题似乎是当ForkJoinPool.commonPool()中运行的任务异步完成新的CompletableFuture时。