在ExecutorService中调用MongoRepository失败
可能是由于以下原因导致的：
- 线程安全问题：ExecutorService是一个线程池，它会同时执行多个任务。如果在多个线程中同时调用MongoRepository的方法，可能会导致线程安全问题，例如数据竞争或死锁。为了解决这个问题，可以使用同步机制（如锁）来保证在同一时间只有一个线程访问MongoRepository。
- 上下文切换问题：在ExecutorService中，任务会被分配给不同的线程执行。如果MongoRepository的方法依赖于线程上下文（如ThreadLocal变量），则在不同的线程中调用可能会导致上下文切换问题。为了解决这个问题，可以在调用MongoRepository之前，将必要的上下文信息传递给任务，或者使用InheritableThreadLocal来实现上下文的传递。
- 异常处理问题：ExecutorService执行任务时，可能会抛出异常。如果没有正确处理这些异常，可能会导致调用MongoRepository失败。为了解决这个问题，可以在任务中捕获异常，并根据需要进行处理或记录。
- 线程池配置问题：ExecutorService的性能和行为可以通过配置进行调整。如果线程池的配置不合理，可能会导致调用MongoRepository失败。例如，线程池的大小不足以处理并发请求，或者任务队列的容量太小导致任务被拒绝。为了解决这个问题，可以根据实际需求调整线程池的配置参数。
总结起来，要在ExecutorService中成功调用MongoRepository，需要注意线程安全、上下文切换、异常处理和线程池配置等问题。确保在多线程环境下正确处理并发访问MongoRepository的情况，并根据实际需求调整线程池的配置。
相关·内容
我对MongoDB v10.16.0使用了NodeJS v3.2.7。我创建了一个MongoRepository基类，我们在生产中使用了几年。有时，在开发中，我会发现一些奇怪的行为，它不会为特定的集合返回任何结果。我以前认为这是因为我没有在查询之间关闭客户端。我现在不太确定。
我正在通过一个Express服务器运行代码，还有六个电话正在正常工作。然后，我得到了这个查询&投影，没有结果(尽管这些结果在命令行和Robo 3T中都是有效的)：
查询= {"pin":"xxxxxx"，"documentId":"5c584a76a690b
浏览 3提问于2019-09-24得票数 0
有N个线程，每个线程在自己的成员变量" status“中将status设置为0或1。在调用方中，如果任何一个线程的状态为1，则整体状态必须变为1。
这些线程以批处理模式运行。因此，如果其中任何一个失败，都需要重新运行。我需要想出一些处理方法来处理失败，这样剩余的线程也会立即停止。
然而，线程是可运行的，而不是可调用的。
我们可以使用易失性布尔变量在线程之间进行通信，以通知失败。但是，我需要知道如何从caller中的runnable线程读取各个状态。
浏览 0提问于2013-02-21得票数 0
回答已采纳
1回答
我用可完成的未来来做一堆事情，X。X与互联网对话，既可以失败也可以不失败。当我调用X时，我传递给它一个值，让我们称它为value。X(value)。
private void X(String value) {
CompletableFuture<Boolean> future = CompletableFuture.supplyAsync(()-> {
try {
Object response = talkToExternalThing(value);
} catch
浏览 3提问于2020-08-11得票数 0
回答已采纳
我尝试在azure上部署一个java spring应用程序。此应用程序使用本地MongoDB 4.0。我试着用Azure CosmosDB代替它。连接是可以的，但是运行我的应用程序测试会产生以下错误：
" .mongodb.UncategorizedMongoDbException:查询失败，错误代码2和错误消息‘投影运算符不支持。’服务器上的…；嵌套的异常是com.mongodb.MongoQueryException:查询失败，错误代码2和错误消息‘投影运算符不支持’。“投影操作符似乎是由MongoRepository类生成的。
import org.springf
浏览 1提问于2019-04-30得票数 0
1回答
首先是一些上下文:我有一个MVC3 .net项目，为了简洁起见，它设置如下所示：
控制器-实例化服务对象(如下所述)-使用服务从mongo检索db记录(例如，_service.GetPerson(id)) --将域传递到视图
服务-实例化MongoRepository (下面描述)-调用方法检索db记录(例如_mongoRepository.Single(c => c.Id == id))
MongoRepository : IDisposable - Constructor (_server =_server-单方法(下)- Dispose方法
public T Single<T
浏览 1提问于2011-05-18得票数 4
回答已采纳
1回答
我想使用线程池读取多个文件，但我失败了。 @Test
public void test2() throws IOException {
String dir = "/tmp/acc2tid2999928854413665054";
int[] shardIds = new int[]{1, 2};
ExecutorService executorService = Executors.newFixedThreadPool(2);
for (int id : shardIds) {
executorService.submit((
浏览 15提问于2019-04-12得票数 3
回答已采纳
我正在编写一个程序，它使用CompletionService对一堆不同的对象运行线程分析，其中每个“分析”都包括接受一个字符串并进行一些计算，以得到true或false作为答案。我的代码基本上是这样的： // tasks come from a different method and contain the strings + some other needed info
List<Future<Pair<Pieces,Boolean>>> futures = new ArrayList<>(tasks.size());
for (Task
浏览 27提问于2021-06-16得票数 0
回答已采纳
我正在尝试使用内置的MongoRepository<T、ID>接口方法与mongo进行交互。
interface MovieRepository : MongoRepository<Movie, String> {
}
但是当我尝试使用类来实现"MovieRepository“时。它还要求我实现"MongoRepository“中定义的所有成员函数。
class ControllerClass(private val MovieRepository: MovieRepository): MovieRepository {}
这就是我初始化控制器类时得到的
浏览 6提问于2022-09-04得票数 0
回答已采纳
3回答
我有一个使用static synchronized方法进行HTTP调用的类。
我也有一台ExecutorService。
有多个Runnable类调用此方法。该方法将接受URL、POST/GET信息和参数，如果响应不是200，则返回一个错误代码，或者返回一个XML字符串，以便由Runnable类进一步处理。
如果多个线程在被放入ExecutorService之后调用这个方法，这样可以吗？它会失败吗？
通过ExecutorService处理多个HTTP调用的理想方式是什么
浏览 2提问于2016-04-21得票数 4
2回答
当尝试将继承与MongoRepository进行C#组合时，我遇到了序列化错误。
真正奇怪的是，它能在很短的时间内发挥作用，但如果说重建或其他一些事情，它就会失败。如果我删除集合并创建一个新集合，它将一直工作到停止或重建为止。
我的代码看起来是：
public class Organization
{
// other attributes removed for demonstration simplicity
public List<Person> People { get;set; }
}
public abstract class Person
浏览 4提问于2013-12-10得票数 12
回答已采纳
我正在开发两个不同的spring启动服务，这两个服务需要访问一个通用的MongoRepository用户集合。
为了简单起见，我们使用SpringBootApp1: User.java
@Document(collection = "user")
public class User {
@Id
private String id;
....
}
public interface UserRepository extends MongoRepository<User, String> {
}
现在我
浏览 5提问于2020-08-18得票数 0
在启动过程中，我的应用程序创建bean，它在任务执行器中调度一些任务，然后在创建另一个bean后失败。这会使我的应用程序处于不死状态，在这种状态下，应用程序看起来正在运行，但并不提供功能。我想知道如何在全局范围内处理BeanCreationException以提供适当的关机。 这是我的示例代码 @SpringBootApplication
@EnableAutoConfiguration
public class Application {
ExecutorService executorService = Executors.newCachedThreadPool();
浏览 14提问于2019-02-14得票数 2
回答已采纳
我正在使用以下扩展：
我尝试创建一个泛型类来管理我的存储库。
但是，我想在MongoRepository中使用泛型类。
我有一个错误：
错误CS0314类型'T‘不能用作泛型类型或方法'MongoRepository’中的类型参数'T‘。没有从“T”到“MongoRepository.IEntity”的装箱转换或类型参数转换。
你知道我该怎么改正我的错误吗？
谢谢!
public class DataService<T>
{
public static Dictionary<Type, MongoRepository<T>>
浏览 2提问于2015-11-06得票数 0
我正在使用教程学习java中的信号量。
本教程中的第一个测试(低于一个)运行良好。
@Test
public void givenLoginQueue_whenReachLimit_thenBlocked() {
int slots = 10;
ExecutorService executorService = Executors.newFixedThreadPool(slots);
LoginQueueUsingSemaphore loginQueue = new LoginQueueUsingSemaphore(slots);
IntStream.range
浏览 0提问于2018-08-31得票数 3
回答已采纳
好的，在工作中，我们正在开发一个使用MVC C#和MongoDB的系统。在第一次开发时，我们认为遵循存储库模式可能是个好主意(这太麻烦了！)，下面的代码给出了当前实现的概念。
MongoRepository类：
public class MongoRepository { }
public class MongoRepository<T> : MongoRepository, IRepository<T>
where T : IEntity
{
private MongoClient _client;
private IMongoDatabase _d
浏览 1提问于2017-02-09得票数 3
回答已采纳
2回答
Java中的并行任务
、、、
假设我有几个任务要在Java中并行运行。每个任务都返回成功或失败。每个任务都有一个相关的截止日期。如果任务在截止日期前未完成，则会被中断(所有任务都是可中断的)并返回失败。
如果其中一个任务失败(即返回失败)，我们中断所有其他仍在运行的任务。
我们应该等到所有任务完成，如果所有任务返回成功，最后返回成功，如果至少有一个任务返回失败，则返回失败。
你将如何实现它？我将使用util.concurrent。你会建议哪些图书馆原语？
浏览 4提问于2013-04-09得票数 0
回答已采纳
我如何将一次两个任务添加到一个执行器(或类似的任务)中，然后等待两个任务中的任何一个完成(即最快)，而另一个任务以及先前开始的任务在后台继续进行？
我知道CompletionService提供了一些类似的东西，但是我所能做的就是等待下一个.take()完成。在我的例子中，这可能来自于以前的调度，而不是我需要等待的其中一个。
我想用伪代码
ExecutorService executorService = Executors.newFixedThreadPool(100);
Future<?> one = executorService.submit(() -> oneWay(
浏览 2提问于2019-11-26得票数 0
回答已采纳
我真的很难找到一种在Java中启动、停止和重新启动线程的方法。
具体地说，我在文件Task.java中有一个类Task (当前实现了Runnable)。我的主应用程序需要能够在线程上启动此任务，在需要时停止(终止)线程，有时还需要终止并重新启动线程……
我的第一次尝试是使用ExecutorService，但我似乎找不到重启任务的方法。当我使用.shutdownnow()时，将来对.execute()的任何调用都会失败，因为ExecutorService是“关闭”的……
那么，我如何才能做到这一点呢？
浏览 12提问于2009-12-10得票数 51
回答已采纳
我得到了一个循环{Loop-1}，我从这里开始线程。包含{Loop-1}的类实现了守护进程和Runnable。在{Loop-1}中，启动的线程调用Coordinate.java类的方法coordinate()，我在该类中使用ExecutorService。
在创建Coordinate.java的对象时(在{Loop-1}之前发生一次)，我实例化了一个ExecutorService pool = Executors.newFixedThreadPool(2);
在coordinate()中，我创建了一个实现Callable的类的两个对象，然后启动它们，并将结果存储在Future results列
浏览 2提问于2012-03-05得票数 0
回答已采纳
是否有人知道如何在Spring数据REST中处理同一事务中的多个实体更新？同样的事情可以在Spring控制器方法中使用@Transactional注释来处理。如果我是正确的，Spring数据REST将在单独的事务中执行每个执行事件。因此，无法以适当的方式处理多个实体更新。
我在同一个事务中更新2个实体(ABC和PQR)并在PQR实体失败时回滚ABC实体。
// ABC repository
@RepositoryRestResource
public interface ABCEntityRepository extends MongoRepository<ABC, St
浏览 1提问于2020-03-27得票数 3
回答已采纳
我有一个包含5个方法的类。在程序中的某个时刻，我想同时运行两个方法。下面的图表说明了我正在谈论的内容。在method2()完成之后，我希望method3()和method4()同时运行。Method3()和method4()本质上做的是完全相同的事情，但它们具有独立的资源，因此不应该被同步。当method3()和method4()完成时，我希望销毁辅助线程，并让程序返回主线程。做这件事最好的方法是什么？ ? 我尝试调用ExecutorService，但这似乎创建了与主线程同时运行的线程，而不是暂停主线程。 ExecutorService executorService = Exec
浏览 28提问于2019-01-16得票数 0
回答已采纳
1回答
我已经安排了需要在部署在tomcat上的Web应用程序中运行的任务。我在Java 8中使用Spring。
我所做的，
配置类
@Configuration
@EnableScheduling
class SchedulerConfiguration implements SchedulingConfigurer {
@ConditionalOnProperty(name = "ScheduleJob1Switch", havingValue = "on")
@Bean
FirstScheduledJob firstScheduledJo
浏览 1提问于2016-02-26得票数 2
回答已采纳
我想使用统一来管理我的mongo存储库，但是当我尝试使用Web.config和LoadConfiguration()注册它时，我得到了一个错误，我无法解密：
“System.ArgumentException”类型的异常发生在Microsoft.Practices.Unity.Configuration.dll中，但未在用户代码中处理
附加信息:在本配置部分中未定义名为"“的容器。
这是我的Global.asax
using System.Web;
using System.Web.Mvc;
using System.Web.Optimization;
using System
浏览 2提问于2015-12-18得票数 1
回答已采纳
我需要编写一个可以使用spring-data和mongodb执行复杂查询的应用程序。我从使用MongoRepository开始，但在查找示例或真正理解语法的复杂查询中遇到了困难。
我说的是这样的查询：
@Repository
public interface UserRepositoryInterface extends MongoRepository<User, String> {
List<User> findByEmailOrLastName(String email, String lastName);
}
或者使用基于JSON的查询，这是我反复尝试的，
浏览 0提问于2013-06-09得票数 118
回答已采纳
我有一个类，它代表一个名为“存档”的蒙古族集合。
@Document(collection = "archive")
public class Message{
@Id
private byte[] messageId;
private String from;
private String to;
// more stuff
}
接口MessagesRepository扩展了MongoRepository：
public interface MessagesRepository extends MongoRepository<
浏览 2提问于2014-08-29得票数 0
回答已采纳
1回答
我对java中的并行编程非常陌生。我编写了两个方法，每个方法并行地操作一组数据。方法A必须在方法B开始之前完成。我想知道执行并行任务的方法何时终止。是：
什么时候所有的任务都完成了？或
在提交所有任务以供执行之后。
NB:，我用java visualVM监视了线程，我意识到线程在状态监视和等待中花费了大部分时间。
浏览 1提问于2017-08-04得票数 2
回答已采纳
1回答
我有以下代码：
List<ObjectA> allObjects = (List<ObjectA>) objArepository.findAll();
for (ObjectA objA : allObjects) {
String location = objA.getUrl();
Client client = utils.createClient();
WebTarget webTarget = client.target(location).path("/testUrl/" + someStr
浏览 1提问于2017-06-20得票数 1
回答已采纳
2回答
考虑以下测试代码：
@Test
public void test() throws InterruptedException {
var latch = new CountDownLatch(1);
Executors.newSingleThreadExecutor().execute(() -> {
latch.countDown();
Assert.fail("Doesn't fail the test");
});
latch.await();
}
它打印异常，但通过。
线程“池-1-线程-
浏览 0提问于2021-11-30得票数 0
1回答
首先，执行一个save()方法，它通过测试直到达到一个条件，如果它是真，则调用saveBankAccountAndRole()方法，如果它是false，则发送一个Mono.error(new Exception("...").。
sizeAccounts(String customerId)方法确实通过了测试。
在saveBankAccountAndRole(BankAccountDto bnkDto)方法中，在执行sizeAccounts()方法之后，测试没有通过，我遗漏了什么？
public Flux<BankAccountDto> findAccountsBy
浏览 1提问于2022-01-25得票数 0
我想从一个runnable线程抛出一个异常，但是不可能从线程抛出它，所以我们可以把chlild线程的状态(任何异常)传递给父线程吗？
我读到过有关thread.join()的内容，但在本例中，父线程要等到子线程完成它的执行。
在我的例子中，我的父线程在一段时间后一个接一个地启动线程，但是当任何线程抛出异常时，它应该通知paent失败，这样父线程就不会启动其他线程。
有没有办法实现它？有人能帮我解决这个问题吗。
浏览 1提问于2012-08-30得票数 0
回答已采纳
我有一个spring服务类，其中我在@PostConstruct方法下向Executor提交了几个任务。我写了一些测试，但它们在所有运行中的行为并不相同。尽管满足了条件，但有时全部通过，有时很少失败。 Class A {
Private final ExecutorService executorService = Executors.newCachedThreadPool();
private final Object obj1
private final Object obj2;
@Autowired
public A(Object obj1, Objec
浏览 24提问于2018-12-30得票数 1
我注意到了mongo的Spring数据中有一些奇怪的东西：
MongoRepository扩展了CrudRepository，findAll()返回了一个Iterable，这在count()方法中是可以的，因为它返回了一个long。
class CrudRepository {
...
Iterable<T> findAll();
long count();
}
在mongo MongoRepository中，findAll()方法returs a List：
class MongoRepository extends CrudRepository {
..
浏览 4提问于2019-09-18得票数 2
回答已采纳
MongoRepository的保存方法是逐个保存文档，或者使用mongo的批量插入功能。我面临的问题是，我将1000个文档的列表传递给存储库，但是性能方面没有任何变化。
Interface MongoRepository<T,ID extends Serializable>
save
<S extends T> List<S> save(Iterable<S> entites)
Specified by:
save in interface CrudRepository<T,ID extends Serializable&g
浏览 9提问于2015-08-11得票数 4
回答已采纳
1回答
我刚刚开始在ASP.NET MVC2中使用NingObject2.0，所以我有一个接口IMongoRepository和一个类MongoRepository。
MongoRepository接收参数字符串集合。
根据我想使用的集合，我在MongoRepository的参数中传递了一个不同的值。我希望我的措辞是正确的，但是我如何根据我使用的控制器映射不同的参数呢？
例如，在文章控制器中，我会调用：
_articlesRepository = new MongoRepository("Articles");
在PageController中，我会调用：
_pagesControll
浏览 0提问于2010-09-03得票数 3
回答已采纳
1回答
我有这样一堂课
import java.util.concurrent.*;
public class TestClass<V> {
private final ConcurrentMap<String, Future<V>> requests;
private final ExecutorService executorService;
public TestClass(final ExecutorService executorService) {
this.executorService = executorS
浏览 2提问于2017-10-23得票数 1
回答已采纳
1回答
我有一个Stream<String>，并对其项执行一些操作，包括处理字符串并将其写入文件。
有下面的groovy代码，并处理100万项----我正在运行这个
ExecutorService executorService = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors())
stream.forEach { item ->
executorService.execute {
handle(item)
}
}
executorService.shu
浏览 0提问于2017-07-03得票数 1
回答已采纳
1回答
我使用SpringBoot、Spring Data和MongoRepository来存储和检索对象。
在使用MongoRepository时，有没有办法提供一个自定义的json反序列化器(最好是GSON，它可以做一些额外的工作，而不是内部的反序列化器)？
例如，我调用：
Data data = repo.findOne(id); // where repo is a MongoRepository
我希望数据以自定义方式设置一些额外的字段(称为派生字段值)。当然，我可以直接在上面的数据对象上设置派生字段，但如果我可以在检索时挂接一个反序列化程序，就会更简洁。
例如，在没有spring数据的情况
浏览 5提问于2017-05-21得票数 1
在我的spring boot应用程序中，我在yml文件中配置了两个数据库。因此，现在我要指定在每个MongoRepository中使用哪个数据库。这个是可能的吗？如果是，该怎么做呢？提前谢谢。
yml文件：
spring:
data:
mongodb:
first:
host: 127.0.0.1
port: 27017
database: db_admin
rest:
base-path: /admin
second:
host: 127.0.0.1
port: 27018
database: `user_forms`
r
浏览 0提问于2019-05-07得票数 1
1回答
我在Mongodb中使用Spring boot并开发我的新应用程序。我可以使用MongoRepository进行数据库操作，也可以使用Mongotemplate。我正在使用mongotemplate来处理我的复杂查询和与POJO的任何字段相关的MongoRepository小查询。
在应用程序中同时使用mongoRepository和MongoTemplate可以吗？
浏览 0提问于2015-11-20得票数 0
2回答
在Scala中，人们写道：
type Par[A] = ExecutorService => Future[A]
他们是这样提到Par的：
def run[A](s: ExecutorService)(a: Par[A]): Future[A] = a(s)
在Java语言中，type(Scala)的等价物是什么？
浏览 0提问于2014-12-30得票数 1
根据Javadocs，将等待所有提交任务的执行。我有两个问题：
提交的任务意味着什么？这些任务是否必须由ExecutorService.submit()方法具体提交，还是包括由ExecutorService.execute()方法提交的任务？
我添加了一个关闭钩子，它调用ExecutorService.shutdown()。根据文档，它应该等待所有提交任务的执行。但是，在关闭()调用之后添加一个awaitTermination()调用之前，它不会这样做。为什么它不执行没有awaitTermination()调用的所有任务？
浏览 0提问于2016-12-27得票数 0
回答已采纳
问题：
我很难让StructureMap在MongoRepostiory命名空间中找到IRepository<>类型的默认实例。
异常消息：
“PublicKeyToken=f686731cfb9cc103”StructureMap异常代码:202个未为PluginFamily MongoDB.Driver.MongoUrl、MongoDB.Driver、Version=1.8.3.9、Culture=neutral、MongoDB.Driver定义的默认实例
似乎StructureMap正在用错误的构造函数实例化MonogoRepository类.
MonogoRepositor
浏览 1提问于2014-02-04得票数 1
关于可重复的例子，我有以下的类
public class SampleCaching {
ScheduledExecutorService executorService;
@com.google.inject.Inject InterestCache interestCache;
@Inject MultimediaCache multimediaCache;
@Inject
public SampleCaching(InterestCache interestCache, MultimediaCache multimediaCache) {
浏览 1提问于2020-04-24得票数 0
回答已采纳
2回答
我想为MongoDB使用带有存储类和接口的DI，但它不起作用。我有一个错误：
MongoRepository`1‘1类型有长度为2的多个构造函数，无法消除歧义。
类构造函数：
public MongoRepository(string connectionString, string collectionName)
{
this.collection = Util<TKey>.GetCollectionFromConnectionString<T>(connectionString, collectionName);
}
浏览 1提问于2014-08-29得票数 5
回答已采纳
我的代码如下：
public Future<String> getFuture() {
ExecutorService executorService = Executors.newSingleThreadExecutor();
Future<String> future = executorService.submit(() -> {
//do something
return "test string";
});
executorService.shutDown(); // is this correct?
浏览 5提问于2017-06-28得票数 3
回答已采纳
我正在尝试为应用程序中的每个实体创建一个通用存储库 mongo-repository.ts import { Document, Model, Types } from 'mongoose';
type MongooseModel<T> = Model<T & Document>;
export abstract class MongoRepository<T extends MongooseModel<T>> {
protected constructor(
protected readonly mod
浏览 4提问于2019-06-21得票数 0
我必须为一个网站编写测试，有时会在加载页面时无限期挂起。我想写一个方法，在它开始运行20分钟后超时。
但当我试图写这样的代码时-
@Test(timeOut=4000)
public void test() {
try { Thread.sleep(5000); } catch (InterruptedException e) {}
System.out.println("I don't want this to print.");
}
测试会打印“我不想这个打印出来”然后在预期的异常- org.testng.internal.thread.Thread
浏览 0提问于2020-12-27得票数 0
回答已采纳
我正在尝试在线程中使用MongoRepository。这有可能吗？ 例如，在服务中，该存储库位于构造函数中，然后您可以调用它。但是如何在线程中执行查询呢？
浏览 19提问于2020-04-15得票数 0
回答已采纳
我有一些使用Java 的服务(在Wildfly 9中)
public class FooService{
@Resource
ManagedExecutorService executorService;
}
在使用Mockito进行测试时，我想使用“普通”
@RunWith(MockitoJUnitRunner.class)
public class FooServiceTest{
@Spy
ManagedExecutorService executorService = Executors.newFixedThreadPool(5);
}
这段代码显然不编译，因
浏览 0提问于2016-06-09得票数 5
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
