草庐IT

node-async

全部标签

java - 如何使用 Mockito 在 Spring Boot 中模拟异步(@Async)方法?

用mockito模拟异步(@Async)方法的最佳方法是什么?提供以下服务:@Service@Transactional(readOnly=true)publicclassTaskService{@Async@Transactional(readOnly=false)publicvoidcreateTask(TaskResourcetaskResource,UUIDlinkId){//dosomeheavytask}}Mockito的验证如下:@RunWith(SpringRunner.class)@WebMvcTest(SomeController.class)publicclass

Java lambda 表达式 : Copy nodes from list to a new list

我对Javalambda很陌生,我不确定我想要的是否可以实现:我有一个对象列表,我想对其进行过滤以提取与给定条件匹配的对象,并将它们放在一个单独的列表中(这样我就可以对它们执行一些操作,保持原始列表不变)我想到了这个:Listonly_translations=original_list.stream().filter(t->t.isTranslation).collect(Collectors.toCollection(()->newArrayList()));但是即使我得到一个新的列表对象,节点似乎链接到原始节点(通过引用,不是从原始列表复制的新对象),所以修改新列表中的对象也是修

java - Spring取消@Async任务

我希望能够在它的future取消标有@Async注释的方法。我有一个用@Async注释标记的Spring方法。该方法进行一些计算,并最终返回一个结果。我见过的所有示例都建议使用AsyncResult类来返回此Future。@AsyncpublicFuturerun(){//...Computation.Minutespass...returnnewAsyncResult("Result");}我以下列方式从另一个组件调用以下方法。出于示例目的,我希望立即取消此线程:Futurefuture=component.run();future.cancel(true);在这种情况下,线程永远不

java - 如何为 Async Spring 使用多个 threadPoolExecutor

我在两个类上使用Spring@Async。两者最终都实现了一个接口(interface)。我正在创建两个单独的ThreadPoolTask​​Executor,因此每个类都有自己的ThreadPool来处理。然而,由于我认为代理和Spring如何实现异步类,我必须将@Async注释放在基本接口(interface)上。因此,这两个类最终使用相同的ThreadPoolTask​​Executor。是否可以告诉Spring对于这个Bean(在本例中我将实现该接口(interface)的类称为服务),使用这个ThreadPoolTask​​Executor。 最佳

java - Apache async HttpClient 速度不快

我是Apachehttp客户端的新手,正在尝试从网站获取状态代码。在Apachehttp教程中找到以下示例。importjava.util.concurrent.CountDownLatch;importorg.apache.http.HttpResponse;importorg.apache.http.client.config.RequestConfig;importorg.apache.http.client.methods.HttpGet;importorg.apache.http.concurrent.FutureCallback;importorg.apache.http.

java - Hibernate 查询给出 java.lang.IllegalArgumentException : node to traverse cannot be null

这个简单的查询session=com.jthink.songlayer.hibernate.HibernateUtil.getSession();Queryq=session.createQuery("recNofromSongChanges");给出这个堆栈跟踪java.lang.IllegalArgumentException:nodetotraversecannotbenull!atorg.hibernate.hql.internal.ast.util.NodeTraverser.traverseDepthFirst(NodeTraverser.java:63)atorg.hib

java - 如何在 java 的 org.w3c.dom.Node 中获取 TEXT_NODE 的标记名

在这个接口(interface)的文档中,它声明文本节点都返回“#text”作为它们的名称,而不是实际的标签名称。但是对于我正在做的事情,标签名称是必要的。//I'musingthefollowingimportsimportjavax.xml.parsers.DocumentBuilder;importjavax.xml.parsers.DocumentBuilderFactory;importorg.w3c.dom.Document;importorg.w3c.dom.NamedNodeMap;importorg.w3c.dom.Node;importorg.w3c.dom.Nod

java - JavaFx/FXML 中的 "Node"是什么?

JavaFx/FXML上下文中的“节点”一词是什么意思?如果我搜索这个问题,我发现的只是人们使用该术语讨论其他问题,但没有任何解释。例如,这个问题的答案:HowdoIopentheJavaFXFileChooserfromacontrollerclass?:Foranynodeinyourscene(forexample,therootnode;butanynodeyouhaveinjectedwith@FXMLwilldo),dochooser.showOpenDialog(node.getScene().getWindow());节点是什么,我将如何“用@FXML注入(inject

java - Spring @Transactional 和 @Async

在我的应用程序中,在创建任务时,我需要对Google进行API调用以创建Google日历事件。我决定在一个单独的线程上进行API调用,这样我们的客户端就不必等待更长时间的响应。@Override@Transactional(rollbackFor=DataException.class)publicTaskResponseBeancreateTask(TaskCreationBeantaskCreationBean,UserAccessDetailsaccessDetails)throwsDataException{StringgoogleEventId="";try{TaskServ

带有 ConcurrentLinkedQueue$Node 的 Java 内存 "Leak"

我遇到了一个有趣的难题,我似乎有内存泄漏(或不断增长的数据结构)。当我分析我的内存使用情况时,我得到了典型的“随时间线性增加”的图表。为了找出问题的原因,我进行了堆转储。我发现超过50%的内存分配给ConcurrentLinkedQueue节点。内存消耗最大的是com.singularity.ee.agent.util.ch和java.util.concurrent.ConcurrentLinkedQueue$Node,如下图所示。我不知道util.ch是什么,但它似乎与节点相关联,因为每个ch都有一个对节点的直接引用,所以不用担心关注它。现在尝试为$Node查找最近的GC的引用,我得