executorservice

    0热度

    2回答

    我写了一个简单的工具,它检查内容的一些xml(解组和内容分析),并为每个xml写入一个日志文件。 我必须检查超过几千个文件,大约2 MB /文件。所以进展需要一些时间。因为我的文件之间没有依赖关系,所以我尝试在不同的线程中完成这项工作(没有同步的方法)。 不幸的是,我的ExecutorService的东西似乎是错的。我试图使用一个fixedthreadpool Executorservice。但是

    1热度

    2回答

    我有一个简单的程序用于两个线程交替地打印增量数字。 所以, 第一线程打印:1个 第二个线程打印:2个 第一线程打印:3 ...等等 我能使用 '线' 类做这个。但我想看看如何使用Executor类来做到这一点。 用以下代码.... executor类似乎不工作。任何指针? 代码: import java.util.concurrent.ExecutorService; import java.u

    0热度

    1回答

    我正在致力于应用程序从java应用程序执行spark批量应用程序。 有一个主线程启动线程来启动spark应用程序。它使用zookeeper在将启动spark应用程序的机器中找到leader。 Main方法是这样的: public static void main(String[] args) throws IOException { final int id = Integer.va

    0热度

    2回答

    我有一个弹簧启动应用程序,我使用ScheduledExecutorService来创建单线程执行程序。在这个单线程中,我处理数据库记录。我获取了许多记录上的锁来处理它们,并希望在JVM关闭后立即释放锁。我试图注册一个JVM关机挂钩。 // Create single threaded ScheduledExecutorService executor;= Executors.newSingleT

    2热度

    1回答

    我在下面的代码段中遇到ExecutorService节Java 8 The complete reference。 下面的代码片段解释了ExecutorService的工作原理。 // A simple example that uses an Executor. import java.util.concurrent.*; class SimpExec { public st

    0热度

    1回答

    我想安排任务仅在一天中的特定时间运行。最简单的方法是什么?我大概可以使用Timer,TimerTask类,但我想知道是否可以对ExecutorService执行相同的操作。

    0热度

    2回答

    我试图扫描我的本地网络以查找带有特定打开的端口的设备。 当我做扫描6-7次我拿出内存不足。 WifiManager wifiManager = (WifiManager) getApplicationContext().getSystemService(WIFI_SERVICE); int ipAddress = wifiManager.getConnectionInfo().getIp

    3热度

    2回答

    我有一个多线程的应用程序,所以我实现ExecutorService 5线程池大小 public class SimpleThreadPool { public static void main(String[] args) { ExecutorService executor = Executors.newFixedThreadPool(5); for (int

    10热度

    1回答

    我有一个执行器服务,我提交多个线程做一些工作,现在我想取消/中断一些线程的执行,让我知道我怎么能做到这一点? 例如: - 下面是我的Thread类,它在无限的时间间隔后打印线程名称。 public class MyThread implements Runnable { String name; public MyThread(String name) { this.name =

    0热度

    1回答

    我有一个需要在for循环中处理的40000条记录的列表。由于我有一个双处理器系统。我创建了一个fixedThreadPool这样的: int threads = Runtime.getRuntime().availableProcessors(); ExecutorService service = Executors.newFixedThreadPool(threads); ,分我ArrayLi