使用ExecutorService详细说明大列表中的项目
：
ExecutorService是Java中的一个接口，它提供了一种管理和控制多线程任务执行的机制。通过ExecutorService，我们可以创建线程池，将任务提交给线程池执行，并且可以灵活地控制线程池的大小、线程的创建和销毁等。下面详细说明大列表中的项目。
- 前端开发： 前端开发主要负责网站或应用程序的用户界面设计和开发。它涉及使用HTML、CSS和JavaScript等技术来创建具有良好用户体验的网页或应用界面。推荐的腾讯云产品：云服务器CVM，详情请参考：https://cloud.tencent.com/product/cvm
- 后端开发： 后端开发主要负责构建和维护应用程序的服务器端逻辑。它涉及使用各种编程语言（如Java、Python、Node.js等）和框架来处理请求、访问数据库、进行业务逻辑处理等。推荐的腾讯云产品：云函数SCF，详情请参考：https://cloud.tencent.com/product/scf
- 软件测试： 软件测试是一种通过运行测试用例来检测软件系统是否符合预期功能和性能要求的过程。它包括单元测试、集成测试、系统测试、性能测试等各个阶段。推荐的腾讯云产品：云测试SIT，详情请参考：https://cloud.tencent.com/product/sit
- 数据库： 数据库用于存储和管理应用程序的数据。常见的数据库技术包括关系型数据库（如MySQL、PostgreSQL）和NoSQL数据库（如MongoDB、Redis）。推荐的腾讯云产品：云数据库CDB，详情请参考：https://cloud.tencent.com/product/cdb
- 服务器运维： 服务器运维涉及对服务器的安装、配置、监控和维护等工作。它确保服务器的正常运行，包括服务器的性能调优、安全性管理、故障排除等。推荐的腾讯云产品：云服务器CVM，详情请参考：https://cloud.tencent.com/product/cvm
- 云原生： 云原生是一种构建和运行在云环境中的应用程序的方式。它通过使用容器化、微服务架构、自动化运维等技术，实现应用程序的高可靠性、弹性伸缩和灵活部署。推荐的腾讯云产品：容器服务TKE，详情请参考：https://cloud.tencent.com/product/tke
- 网络通信： 网络通信涉及将数据从一个计算机传输到另一个计算机的过程。它涉及使用各种网络协议（如TCP/IP、HTTP、WebSocket等）来实现数据传输和通信。推荐的腾讯云产品：云通信IM，详情请参考：https://cloud.tencent.com/product/im
- 网络安全： 网络安全是保护计算机网络不受未授权访问、数据泄露、恶意软件等威胁的一系列措施和技术。它包括身份验证、访问控制、加密通信等方式来确保网络的安全性。推荐的腾讯云产品：Web应用防火墙WAF，详情请参考：https://cloud.tencent.com/product/waf
- 音视频： 音视频技术涉及处理和传输音频和视频数据。它包括音频编解码、视频编解码、媒体流传输、实时音视频通信等技术。推荐的腾讯云产品：云直播CSS，详情请参考：https://cloud.tencent.com/product/css
- 多媒体处理： 多媒体处理涉及对音频、视频、图像等多媒体数据进行编辑、转码、剪辑等处理。它包括格式转换、分割合并、特效添加等操作。推荐的腾讯云产品：云点播VOD，详情请参考：https://cloud.tencent.com/product/vod
- 人工智能： 人工智能是一种使机器具备类似人类智能的技术和应用。它包括机器学习、深度学习、自然语言处理、计算机视觉等方面的技术。推荐的腾讯云产品：智能图像处理OCR，详情请参考：https://cloud.tencent.com/product/ocr
- 物联网： 物联网是将物理设备、传感器、网络和云计算技术连接起来，实现设备之间的互联和数据交换。它包括物联网设备管理、数据采集、远程控制等方面的技术。推荐的腾讯云产品：物联网开发平台TIoT，详情请参考：https://cloud.tencent.com/product/tiot
- 移动开发： 移动开发涉及开发适用于移动设备（如手机、平板电脑）的应用程序。它包括Android开发和iOS开发两个方向。推荐的腾讯云产品：移动应用开发平台CAP，详情请参考：https://cloud.tencent.com/product/cap
- 存储： 存储涉及将数据永久保存在计算机系统中的过程。它包括文件存储、对象存储、块存储等不同类型的存储方式。推荐的腾讯云产品：对象存储COS，详情请参考：https://cloud.tencent.com/product/cos
- 区块链： 区块链是一种分布式账本技术，用于记录和验证交易数据。它提供了去中心化、不可篡改、可追溯的特性，被广泛应用于数字货币、供应链管理、智能合约等领域。推荐的腾讯云产品：区块链服务TBC，详情请参考：https://cloud.tencent.com/product/tbc
- 元宇宙： 元宇宙是一个虚拟的数字世界，模拟了现实世界中的环境和物体，并提供了交互和沟通的能力。它涉及虚拟现实、增强现实、人工智能等技术。推荐的腾讯云产品：云游戏GSE，详情请参考：https://cloud.tencent.com/product/gse
相关·内容
3回答
我有一个活动，它有两个listview。第一个列表视图有音乐。第二个listview显示下载项目，每个下载项目显示下载百分比的进度条。如果用户点击音乐项，我会在第二个列表视图中添加一个下载项，并使用AsyncTask开始下载文件。用户可以点击多个音乐，这意味着同时下载多个文件。我可以用AsyncTask下载文件。但我想下载服务中的文件，因为下载必须继续，即使应用程序关闭。
我不知道如何使用服务同时下载多个文件。我应该遵循哪些步骤？有没有关于这方面的教程？
浏览 3提问于2017-02-10得票数 1
回答已采纳
因此，下面是我对管理队列中的运行表的第一个猜测。他们一个接一个地被处决。在这一点上，只有一个问题：
如何定期检查前一个线程是否仍在运行，以避免开始执行列表中的第二个线程？
qe=new LinkedList()；for (int i= 0；i< 5；i++) { RunnableObject ro =新RunnableObject()；qe.add(ro)；} for (int i= 0；i< qe.size()；i++) { qe.peek().start；qe.poll()；}
浏览 5提问于2013-09-13得票数 1
回答已采纳
1回答
我有一个包含3个对象的列表，我想同时对每个对象调用一个方法。
通常，我会循环遍历列表中的每个对象，并对每个对象调用该方法。
for(Object object : myList){
object.someMethod();
}
这将从someMethod()逐个调用每个对象的myList。我可以同时调用每个对象的someMethod()吗？
浏览 1提问于2019-01-15得票数 1
回答已采纳
我正在创建程序，在线程的帮助下并行运行一个逻辑。逻辑必须在一个列表的循环中完成，该列表可能包含1000行要处理，所以我在一个循环中启动了每个线程，一旦线程大小达到5，我将对所有5个已启动的线程调用thread.join。那么，我认为这将启动第二组的5个线程，只有在第一组5个线程完成后？我的理解正确吗？我对线有点陌生。
所以，我需要的是启动第6个线程时，任何一个前一组的5个线程在完成。或者，当前一组线程中的任意2完成时，启动第6和第7。
我的代码
public static void executeTest(){
for (int i = 0; i < rows1; i+
浏览 1提问于2022-10-12得票数 0
回答已采纳
3回答
我正在处理一个返回List<Response>对象的服务。
有两种对象可以构建响应。其中一个从内部数据中填充内容，另一个从服务中获取数据。
for(Item item : items){
if(item is external){
call service and get result and populate Response and add to List
}
if(item is internal)
{
populate response object and add to list
}
}
目前的推动是程序性和阻塞，我想要
浏览 0提问于2012-11-21得票数 2
回答已采纳
4回答
我有一组预先填充的字符串。我想要迭代项目，在迭代的同时，我需要“做工作”，这可能也会从集合中删除项目。我想为每个项目的“工作”产生一个新的线程。请注意，在“做工作”期间，只有一些项目会从集合中删除。
现在我有以下问题，
我能通过简单地使用Collections.synchronizedSet(new HashSet())；来实现这一点吗？我猜这会抛出ConcurrentModificationException，因为我在迭代时从列表中删除了项。如何才能在没有一致性问题的情况下高效地实现上述行为？
谢谢!
浏览 0提问于2012-07-23得票数 3
1回答
我在Hibernate中使用Spring 1.5.2。
我有一张物品清单。每个对象包含许多属性和@OneToMany关系(即从数据库获取该对象并将该对象更新到数据库需要很长时间)。
这就是为什么我使用定制的JPQL查询：
一个用于加载对象列表的基本属性。
一个用于更新对象所需的属性。
@Entity
@Table(name = coverage)
@Inheritance(strategy = InheritanceType.JOINED)
public class Coverage implements Serializable {
@Id
@JsonIgno
浏览 1提问于2021-09-28得票数 1
2回答
我将为列表中的每个对象启动一个新线程，并对这些对象调用一个方法。我调用的方法返回一个想要保存的值，如下所示：
public int[] benchAll(){
int[] numbers = new int[things.size()];
for (final Thing thing: things) {
final Generator generator = new Generator();
new Thread(
() -> generator.benchmark(thing)
浏览 4提问于2015-06-08得票数 3
回答已采纳
1回答
为了代码重用，我似乎总是依赖于Factory模式/继承，并且一直在阅读关于组合而不是继承的内容，并且确实看到了松散耦合的好处。您肯定会获得继承的依赖项。因此，我试图围绕“处理”对象的模式进行思考。
基本上，
从数据库中获取他们的“环境变量”，
找出一份文件清单，
处理/转换每个文件(考虑将XML转换为CSV)，这需要
逐行读取文件
将文件写入另一种格式，逐行写入
更新状态(向数据库写入状态)
获取文件列表可能意味着从本地目录获取文件列表，或从远程FTP站点获取文件列表。
我正在努力解决的问题是，使用复合技术是代码重用。使用继承，如果我有一个基本抽象类，我可
浏览 1提问于2012-10-04得票数 0
回答已采纳
1回答
解雇秋千工人
、、
祝大家节日快乐：
我的工作是为我们的客户创造定制的工具。我的雇主有一个旗舰产品，我们销售，有一个Java接口。然后，我为我们的客户构建工具(用Java)，使他们的生活更容易。这些工具作为从Java接口内部启动的插件运行。
我的问题是，在正常操作期间，我喜欢使用SwingWorkers来做事情。在调试期间，我开始注意到(使用NetBeans调试器)，即使完成了给定的SwingWorker，线程仍然在运行。通常情况下，这与我无关，但后来我开始注意到，即使我正在工作的工具已经关闭，挥杆工人仍然在游泳池里闲逛。如果我关闭了主应用程序，当然，当JVM终止时，所有线程都会死掉，但是如果主应用程序仍然在运行
浏览 2提问于2015-11-12得票数 2
回答已采纳
1回答
共享对象设计模式
、、、
我对如何解决以下问题感到有点困惑：
我有一个大型(java se)应用程序，它基于生产者-消费者模型，主要工作是多线程。例如，10个线程正在获取消息，40个线程正在消耗消息。现在我有了对象，这些对象需要在所有线程中共享，比如一个ThreadPoolExecutor。伪码：
ExecutorService execService =
new ThreadPoolExecutor(10, 10, 1, TimeUnit.SECONDS, some_queue);
execService.submit(new Consumer(sharedEntityManagerFactory)
这些使用者线
浏览 5提问于2015-05-06得票数 2
回答已采纳
假设我有一个接受一系列请求的ExecutorService (.newFixedThreadPool(2))。为了简单起见，它们只是：{ String url }
假设我的urls是按这个顺序排列的[ aaa, bbb, ccc, aaa, ddd, aaa, ... ]。(是，aaa重复多次)
这些url事件是异步传入的，因此每个事件都会在它们到达时提交给ExecutorService。
有没有办法让ExecutorService在允许下一个挂起的项目运行之前检查一个条件？例如，检查将来的未决结果是否包含'aaa‘，如果包含，则丢弃它，以便只触发最近的结果。
我想出了一种老生常谈的方
浏览 3提问于2016-06-07得票数 0
2回答
我调用了一个从多个线程向列表中添加项的方法，该方法不同步。
static List<String> list = new ArrayList<String>();
static void addItem(int itemNo){
list.add("item "+itemNo);
}
public static void main(String[] args) {
ExecutorService executor = Executors.newFixedThreadPool(4);
for (int i =
浏览 1提问于2017-05-23得票数 1
回答已采纳
1回答
我有一个带有值的列表，我想使用该列表使用executor服务调用一个函数，该函数只有一个参数字符串。例如我有-
private List<String> namesList = new ArrayList<>();
private ExecutorService exeService = Executors.newFixedThreadPool(10);
private void printNames(String name);
我想使用列表值与executor服务并行调用这个函数printNames，也就是说，如果我的列表大小为10，那么对于列表数据，这个函数应该
浏览 2提问于2022-01-21得票数 0
1回答
如何提高骆驼的使用效率？
、、、
我的项目效率有问题，我的项目使用骆驼与。
我有几个外部数据源，向骆驼端点提供信息。接收数据的每个Camel端点将其传输到处理它的路由，然后将其传递到Esper端点。
下面的图像说明了这种行为：
效率问题是，所有这些都是由单个Java线程完成的。因此，如果我有很多资源，就会有一个巨大的瓶颈。
下面的代码准确地说明了图像所发生的情况：
public final void configure() throws OperationNotSupportedException{
RouteDefinition route = from("xmpp://localhost:5222
浏览 3提问于2014-02-23得票数 1
回答已采纳
3回答
在Java中，我有一个函数以某种方式处理文本文件。但是，如果花费太多的时间，该进程很可能对该文本文件毫无用处(不管原因是什么)，我想跳过它。此外，如果进程花费的时间太长，它也会使用太多的内存。我试过用这种方法解决这个问题，但没有用：
for (int i = 0; i<docs.size(); i++){
try{
docs.get(i).getAnaphora();
}
catch (Exception e){
System.err.println(e);
}
}
其中docs只是目录中文件的List。通常，我必
浏览 2提问于2013-04-20得票数 9
2回答
我有一个很长的列表选择器。当页面第一次加载时，它在列表中有10个项目，当用户向下滚动列表时，当他到达列表的底部时，我想添加10个项目到列表中。
我尝试了很多方法来捕捉滚动的结尾，但在WP8中找不到任何事件。
浏览 19提问于2014-04-16得票数 1
我有一个使用executor服务处理的对象列表，并且所有东西都正常工作，因为我没有显式地返回正在运行的线程中的任何内容。
我想要改变-我希望能够返回一个包含调用的所有结果的对象列表。我想我需要使用期货，但我还没有找到我真正需要的东西(我怀疑这是一个简单的解决方案)
ExecutorService executorService = null;
//List<MyObject> allResults = new ArrayList<MyObject>();
try {
// Initialize the executor serv
浏览 1提问于2019-01-30得票数 1
回答已采纳
我目前正在尝试实现一个可以在几个不同线程中运行的系统列表：
1)第一线程正在监听传入的请求，并将其添加到列表中。
2)为每个请求创建一个新线程，用于执行某些操作。
3)另一个线程遍历列表，检查每个请求的状态，并在完成时将它们从列表中删除。
现在，我用一个非常简单的伪代码实现它的方式可以在下面看到：
private List<Job> runningJobs = new ArrayList<>(); // our list of requests
private Thread monitorThread;
private Runnable monitor = new R
浏览 55提问于2018-06-09得票数 0
回答已采纳
2回答
在下面的代码中，由于发送电子邮件花费的时间太长，userList获得了大量数据。
我如何加快应用程序的速度，使50000封电子邮件的发送速度更快？也许可以使用ExecutorService？
List<String[]> userList = new ArrayList<String[]>();
void getRecords() {
String [] props=null;
while (rs.next()) {
props = new String[2];
props[0] = rs.getString("useremail
浏览 13提问于2012-09-06得票数 0
在下面的示例中，如果我同时使用它们(不确定这是否是一个好习惯)，那么实际超时是什么？
ExecutorService executorService = executorServiceFactory.createThreads(2);
List<Callable<T>> tasksList = new ArrayList<>();
tasksList.add(task1);
tasksList.add(task2);
executorService.invokeAll(taskList);
// get the result object with 5
浏览 7提问于2022-10-27得票数 -1
回答已采纳
我有一个单线程池ExecutorService对象。在将来的某个时候，会添加要使用submit()方法完成的任务。我的理解是，submit会将提交的Runnable添加到要完成的任务列表的末尾。然而，我有一种情况，基于布尔值，我可能想要将runnable提交到要执行的任务的前面。我不希望这影响当前的任务，只希望下一个完成的任务将是我刚刚给它的那个。下面重现了一个示例方法。我该怎么做呢？
谢谢
private ExecutorService singleLoadPool = Executors.newSingleThreadExecutor();
public void submitTask(R
浏览 2提问于2012-08-02得票数 5
回答已采纳
在main方法中，使用java1.5执行器服务机制启动子线程。如何让主线程等待到子线程完成？
public class MainClass {
public static void main(String[] args) {
ExecutorService executorService=null;
try {
executorService=Executors.newFixedThreadPool(1);
executorService.execute(new TestThread());
浏览 4提问于2011-09-10得票数 6
1回答
第一种情况:假设你有很多任务都返回某种类型的结果，现在就叫它‘result’，这些都必须存储在一个数组列表中。有两种选择：
1)在main方法中创建一个arraylist，并使用runnables访问共享列表和同步的add方法
2)在main方法中创建一个arraylist，使用callable执行任务并返回结果，让main方法将结果添加到列表中。
两者之间是否存在性能差异，因为runnable需要同步访问，而callables不需要？
然后，到第二种情况:现在假设每个任务生成一个“小”数组列表，假设每个任务少于10个项目。这又提供了两个选项：
1) main和runnables中的一个数组列
浏览 0提问于2016-06-03得票数 0
首先，我想说的是，我正在从python到更复杂的代码。我现在开始使用Java了，而且我还是个新手。我知道Java非常擅长多线程，这一点很好，因为我使用它来处理to级的数据。
数据输入只是输入到迭代器中，我有一个类，它封装了一个run函数，该函数从迭代器中取出一行，执行一些分析，然后将分析写入一个文件。线程之间必须共享的唯一一点信息是它们要写入的对象的名称。很简单，对吧？我只想让每个线程同时执行run函数，这样我们就可以快速迭代输入数据。在python中，它会很简单。
from multiprocessing import Pool
f = open('someoutput.csv
浏览 0提问于2012-12-07得票数 1
回答已采纳
我正在使用SomeService中的ThreadPoolExecutor对数据执行一些工作。问题是SomeServiceTest在调度到ThreadPoolExecutor中的工作线程完成之前完成。我想要SomeService线程加入工作线程。在执行器启动的时候，有没有办法将父线程和工作线程连接起来？
任何帮助都将不胜感激。
浏览 0提问于2011-07-04得票数 0
回答已采纳
2回答
我想用Java构建自己的ExecutorService，它能够提交给定的任务(可调用的任务)。我打算使用一个线程池，它包含几个‘线程(可运行的目标)’。其思想是创建一个固定数量的线程，将FutureTask对象从已被“submit”方法填充的列表中排出队列。FutureTask对象也是在submit方法中创建的。我的问题是，我只能在创建线程时(通过构造函数)将一个可运行的对象(此处为: FutureTask)交给线程，但显然FutureTasks需要动态地分配给线程(当项目从列表中删除时)。有办法这样做吗？
// content of submit, parameter: myTask
Fut
浏览 0提问于2019-06-01得票数 2
回答已采纳
我有一个TicketDTO对象列表，其中每个TicketDTO都需要通过一个函数将数据转换为TicketDataDTO。这里我想要的是减少运行这段代码所需的时间，因为当列表大小更大时，转换它需要很多时间，并且通过GET映射获取数据是不可接受的。但是，当我尝试使用parallelStream) (下面的代码)来实现ForkJoinPool时，我的return List`是空的。谁能告诉我我做错了什么？ @Override
public List<TicketDataDTO> getOtrsTickets(String value, String startDate, String
浏览 16提问于2020-11-24得票数 1
回答已采纳
6回答
线程实现具有列表的for循环迭代
、、、、
下面有一个简单的代码。这将检查服务器列表的活动状态。请您让我知道如何可以并行使用线程或任何其他适当的解决方案。
List<Host> hosts = this.getAllHosts();
List<Host> aliveHosts = new ArrayList<>();
if (hosts != null && hosts.size() > 0) {
for (Host host : hosts) {
try {
浏览 9提问于2017-07-20得票数 2
回答已采纳
我这里有一段代码，它需要很长时间才能运行。代码基本上遍历了文件列表中的每个文件，并做了一些事情。如何创建4个线程并让每个线程处理一个文件(因为只有4个文件)。 public static void run(String referenceFile, String dir) throws FileNotFoundException, IOException
{
List<Gene> referenceGenes = ParseReferenceGenes(referenceFile);
List<String> filenames = ListGenba
浏览 25提问于2020-10-20得票数 0
1回答
用并行流生成列表
、、、、
我有一个Json列表，其中包含了 lists 的列表。我需要收集那些电影，对它们进行处理，并将它们存储在磁盘中。我正在考虑使用并行流方法收集电影并测试其性能。我的方法是：
下面的方法生成电影列表。
protected abstract List<T> parseJsonString(JsonIterator iter);
此方法包含一个并行流，该流收集流中生成的所有列表( List ，List<List<Movies) )的列表：
public CompletableFuture<List<List<T>>> parseJsonPag
浏览 0提问于2021-01-05得票数 1
我正在安排特定延迟的任务来处理我的项目：
while (currentPosition < count) {
ExtractItemsProcessor extractItemsProcessor =
getExtractItemsProcessor(currentPosition, currentPositionLogger);
executor.schedule(extractItemsProcessor, waitBetweenProzesses, TimeUnit.SECONDS);
waitBetweenProzesses += sle
浏览 0提问于2019-03-29得票数 0
回答已采纳
2回答
多线程能同时处理来自同一个列表的值吗？例如，我们有3个线程和它们必须执行的任务列表：
ExecutorService executor = Executors.newFixedThreadPool(3);
List<Strng> tasks = Arrays.asList("firstTask", "secondTask", "thirdTask", "foiuthTask", "fifthTask");
线程开始工作并接受前三个任务，但第二个线程最快地完成了任务。现在它需要第四个任务来工作，如果它没有
浏览 3提问于2022-11-02得票数 0
我想从一个runnable线程抛出一个异常，但是不可能从线程抛出它，所以我们可以把chlild线程的状态(任何异常)传递给父线程吗？
我读到过有关thread.join()的内容，但在本例中，父线程要等到子线程完成它的执行。
在我的例子中，我的父线程在一段时间后一个接一个地启动线程，但是当任何线程抛出异常时，它应该通知paent失败，这样父线程就不会启动其他线程。
有没有办法实现它？有人能帮我解决这个问题吗。
浏览 1提问于2012-08-30得票数 0
回答已采纳
2回答
我目前正在做一个项目，在用户点击时自动抓取网页内容，但我遇到的一个问题是，我需要在不同的时间、不同的时间、不同的秒内运行这些方法。我已经提到了@Schedule和TimerTask，但它们只能在固定的时间内工作。我的案子有什么解决办法吗？
代码示例：
public void run(String selectedWeb) {
if(selectedWeb.equals("First Web")) {
scrapeFirstWeb(); //Need this method auto execute on 8, 30, 42 seconds every minu
浏览 1提问于2021-06-12得票数 1
回答已采纳
我有一个非常具体的应用程序架构问题。
我需要解析大量的传入目标，这些对象的解析是异步处理的，完成后需要将这些对象传递到下一个阶段。
因此，真正的问题可以归结为，什么是处理大量Future对象的优雅方法。
我是不是应该把它们放到一个列表中，遍历该列表，并在完成后删除它们？由于持续的并发访问，列表很可能会被活锁，成为一个很大的瓶颈。
如果我的问题表达得相当含糊，很抱歉。
浏览 2提问于2014-02-14得票数 2
因此，我决定创建自己的Platform，PlatformImpl，类似于实现，以基本上避免在不需要同步和同步的地方出现密集的同步和同步问题，我的要求是，我有一个线程，可以从JFXAT或其他碰巧在其中的线程中抛出。我现在所做的是从JFXAT创建线程，例如，用户必须在用户输入时从数据库中删除一些内容，然后在模型中反映这种更改等等，因为我不希望在JFXAT上发生通信。
，我是不是有点过火了？我喜欢JavaFX和swing有专门的线程，您只需将工作抛到其中，而不必期望出现任何问题，我所创建的线程实际上只需要一个线程，在这个线程中，作业队列将根据需要不断执行。最好采用先进先出结构在中进行补偿。
已经有了
浏览 0提问于2016-08-24得票数 0
回答已采纳
6回答
我有一个的列表，只读取数据，这些数据是我想要处理的互联网上的一组端点。我在想，在课堂或模式中是否有我应该遵循的模式来处理这个问题呢？
现在，我只是将初始列表转换为N个块，并创建N个线程来处理每个请求。
浏览 10提问于2011-03-21得票数 0
回答已采纳
4回答
我有一个简单的任务:有一个数组列表，我需要使用线程池在所有数组中找到除以10的数字。
以下是我的代码
导入java.util.List；
可运行的实现：
public class MyRunnable implements Runnable {
private List<Integer> numbers;
private int[] arrayToFind;
public MyRunnable(List<Integer> numbers, int[] arrayToFind) {
this.numbers = numbers;
浏览 0提问于2014-09-28得票数 0
我得到了一个循环{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
回答已采纳
从前端调用rest控制器后，我需要调用一些延迟的操作。例如，在使用方法更新调用端点/controller之后。我希望在控制器调用调度器中获得响应状态OK，它将在调用端点后的15分钟后对数据库中的实体执行一些更新功能。我只想简单地改变2个布尔型字段与延迟。我应该使用什么？@Schedule注解，或者只是睡眠，或者其他什么？我将非常感谢所有的建议。 诚挚的问候!
浏览 19提问于2019-12-14得票数 1
回答已采纳
1回答
当空队列被下一个线程填充时，如何添加延迟？例如：
int numberOfThreads = 55;
private static ExecutorService executor = Executors.newFixedThreadPool(numberOfThreads);
int counter=0;
for(TblHomePageUrl tblHomePageUrl : mainTable)
{
legalInstituteIDList.add(tblHomePageUrl.getIntLegalInstitutionID());
WPCrawlerThread
浏览 2提问于2014-03-14得票数 0
回答已采纳
我有一个派生自java.util.concurrent.AbstractExecutorService的类。我的课压倒了shutdownNow()。一切都很好地编译和运行。
我把org.eclipse.jdt.annotation.@NonNullByDefault添加到了班上。除了shutdownNow()上的一个错误之外，我设法修复了所有的错误和警告。错误信息说..。
返回类型与从ExecutorService.shutdownNow()返回的“列表”不兼容(不匹配空约束)
快速修复没有任何帮助。
这是违规代码。
@NonNullByDefault // Adding thi
浏览 0提问于2016-11-21得票数 0
回答已采纳
我有一个Spring Boot Application。
我的应用程序使用restTemplate向另一个应用程序发送请求。
我需要发送一个请求到100个不同的应用程序(在不同的服务器上)。我用：
publi class Service {
private RestClient restClient;
private List<String> urls;
private ThreadPoolExecutor executor;
public Service(RestClient restClient, List<String> urls
浏览 0提问于2019-03-20得票数 0
回答已采纳
1回答
Java -单线程执行器
、、、、
我有多个生产者和一个消费者的阻塞队列(足以进行项目的后处理)。
生产者通过调度开始，将任务发送到执行器池，然后由工作人员将任务添加到队列中。
我的问题是如何启动消费者线程？
目前，我有@EventListener (SpringBoot)，它将start发送到singleThreadExecutorPool方法，该方法在无限的while循环中为队列提供服务，对于这种情况，也许有更好的解决方案。看起来是非常常见的使用队列的模式。
浏览 0提问于2017-10-31得票数 2
1回答
我的列表包含了大量的数据( e，g，50k左右)。我需要对每个列表项执行一些操作，然后必须将处理结果映射到java对象以写入csv。到目前为止，这方面的顺序代码对我来说还不错。
list.stream().map(listItem->
service.methodA(listItem)
.map(result ->mapToBean(result, listItem))
).flatMap(Optional::stream).collect(Collectors.toList());
这个操作很慢，2k数据处理大
浏览 2提问于2022-10-31得票数 0
我正在从多个线程修改相同的列表，难道它不应该在迭代列表时触发ConcurrentModificationException吗？
如何才能触发此异常？
public class ConcurrentTest {
static List<String> list = setupList();
public static List<String> setupList() {
System.out.println("setup predefined list");
List<String> l =
浏览 3提问于2019-11-19得票数 2
回答已采纳
这是我的问题，我已经创建了一个服务类来处理将文件从输出文件夹上传到云。在此输出文件夹中，当触发时将生成大量文件。 下面是我的服务类。 @Service
Public class uploadService {
public void UploadAllFile(String processCode) {
if (processCode = "allfile") {
1 //no need check generate status, start to uplo
浏览 16提问于2021-03-26得票数 0
回答已采纳
假设我有n个线程同时从共享队列中获取值：
public class WorkerThread implements Runnable{
private BlockingQueue queue;
private ArrayList<Integer> counts = new ArrayList<>();
private int count=0;
public void run(){
while(true) {
queue.pop();
浏览 0提问于2017-11-07得票数 0
我正在使用ExecutorService(全局声明)同时运行多线程。ExecutorService需要一个小时才能完成任务。因此，我需要获得当前运行的线程详细信息，如活动线程，排队线程和已完成线程。
当我杀死ExecutorService时，ExecutorService杀死了但是线程在后台运行。因此，在关闭ExecutorService之前，我需要从ExecutorService中获取线程对象，并使用循环或迭代器手动关闭线程。
例如：
ExecutorService有5个线程。
每个线程都通过invokeall()执行。每条线将在一小时后结束。
但问题是，我需要在15分钟内停止发送新的请求到
浏览 7提问于2016-11-28得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
腾讯会议活动推荐
腾讯云开发者
