草庐IT

【JavaEE】线程池

全部标签

java - 一个线程中对非 volatile 成员变量的赋值是否保证在另一个线程中可见?

考虑下面的Java示例。请注意,两个类成员变量都未声明为volatile。如果我正确理解内存模型和“先于发生”规则,Java实现可以优化run()方法,使其永远运行,即使另一个线程调用stopNow()方法。发生这种情况是因为run()方法中没有任何内容强制线程多次读取stop的值。那是对的吗?如果不是,为什么不呢?classExampleimplementsRunnable{booleanstop=false;intvalue=0;publicvoidstopNow(){stop=true;}publicintgetValue(){returnvalue;}@Overridepubl

Java - 终止线程中的方法

我有一个Java线程,它的运行方法可以计算很多东西。您可以将其视为一系列数学语句,如下所示。请注意,每个计算都可能使用其他方法,而这些方法又可能有额外的循环等。publicvoidrun(){[computation1goeshereherethattakesafewseconds][computation2goesherethattakesafewseconds]....[computation30goesherethattakesafewseconds]}有一个GUI可以在这些语句产生结果时打印这些语句的输出,我希望用户能够随时说“停止”。下面是我想到的两种方法方法1:许多bool

java - quartz 工作比。立即执行一次性任务的线程

假设我有一些工作单元需要完成,我想相对于我的应用程序的其余部分异步完成它,因为它可能需要很长时间,例如10秒到2分钟。为此,我正在考虑两种选择:安排一个Quartz作业,将一个简单的触发器设置为仅触发一次并尽快触发。创建一个Runnable实例,将其交给Thread,然后调用run();。在上述情况下,我有以下问题:使用Quartz作业给我带来了什么线程没有的东西?使用runable给我带来了什么,而使用quartz作业却没有?就最佳实践而言,应该使用什么标准来决定此用例的Quartz作业和可运行对象? 最佳答案 使用Quartz,

java - 如果它实际计算就不可能中断线程?

鉴于此代码...publicclassSimpleTest{@TestpublicvoidtestCompletableFuture()throwsException{Threadthread=newThread(SimpleTest::longOperation);thread.start();bearSleep(1);thread.interrupt();bearSleep(5);}publicstaticvoidlongOperation(){System.out.println("started");try{booleanb=true;while(true){b=!b;}}ca

JavaFX : After setting text in textArea, 在单独的线程中设置滚动到底部不起作用

我创建了一个JavaFX应用程序,我在其中使用一个后台进程更新日志。所以我在TextArea中设置日志文本并使用logs.setScrollTop(Double.MAX_VALUE)设置滚动到底部。但滚动条设置为从底部向上一点。我还尝试了ScrollPan中的TextFlow并使用logDisplay.setVvalue(1.0)设置滚动到底部。它也给出了相同的结果。Platform.runLater(()->{logs.setText([settinglogtext]);//TextArealogslogs.setScrollTop(Double.MAX_VALUE));});//F

java - 我如何测量有多少线程正在执行一段代码?

我正在尝试测量有多少线程同时执行一段代码。目前我正在(ab)为此使用信号量,有没有更好的方法?finalintMAX_THREADS=Integer.MAX_VALUE;Semaphores=newSemaphore(MAX_THREADS);s.acquire();//startofsection//dosomecomputations//trackhowmanythreadsarerunningthesectiontrackThreads((MAX_THREADS-s.availablePermits()));s.release();//endofsection

java - 为什么要恢复在线程池线程中运行的任务的中断标志

此片段来自JCIP(BrianGoetz)list6.15f.get()抛出InterruptedException和ExecutionException。现在,这些异常(exception)是特定于future的吗?意味着future所代表的特定任务被中断或有内部异常。问题-为什么我需要使用“Thread.currentThread().interrupt()”恢复中断?,因为我的任务运行的线程的中断标志不是吗?这有点令人困惑。为什么抛出launderThrowable异常?如果其中一个downloadImage有问题,我们不应该只处理其他下载的图像而不是从这里扔掉,从而“不”处理剩

java - 线程创建监听器

java可以写线程创建监听器吗?例如使用aop?!我的意思是这样的,如果我的应用程序创建了一个线程,我想在我自己的表、容器或其他东西中注册这个对象。 最佳答案 我会创建一个线程,不断列出JVM上所有正在运行的线程。然后,每次它注意到出现了一个新线程时,它都会以任何一种方式通知您代码中的一个类。这里有一些关于如何列出当前在JVM上运行的所有线程的链接:GetaListofallThreadscurrentlyrunninginJavaListingAllRunningThreads============起始代码:ThreadCrea

java - Java 中的信号量和线程池

我不是很清楚Java中信号量的概念并试图理解它。我看了oracledocs(http://docs.oracle.com/javase/1.5.0/docs/api/java/util/concurrent/Semaphore.html)和其他一些页面后的理解,它类似于锁计算许可数量。它通常用于创建资源池。在这里我感到困惑,还有ThreadPoolExecutor可以给我一个线程池。那么区别是什么呢?在什么场景下使用哪个? 最佳答案 首先,没有愚蠢的问题...Semaphore允许多个线程“获取”资源。他们应该检查资源是否可用。它就

java - "private final Object"锁在java多线程中有什么用?

Java多线程中“privatefinalObject”锁定的用途是什么?就我的理解而言,我认为要使一个类成为线程安全的,我们应该在我们将所有方法标记为同步的地方使用内部锁定,然后使用“this”将它们锁定在对象的监视器上?或者我们可以用方法内部的私有(private)最终对象锁替换在类的“this”上标记为同步的方法,以锁定通用对象锁以使其线程安全?例如使用内部锁定的代码:publicclassCounter{//Locksontheobject'smonitorpublicsynchronizedvoidchangeValue(){//...}我们可以用下面的外部锁替换上面的代码: