返回首页

线程池队列大小设置?

186 2024-04-03 12:09 admin

一、线程池队列大小设置?

一、ThreadPoolExecutor的重要参数

corePoolSize:核心线程数, 核心线程会一直存活,及时没有任务需要执行,当线程数小于核心线程数时,即使有线程空闲,线程池也会优先创建新线程处理,设置allowCoreThreadTimeout=true(默认false)时,核心线程会超时关闭

queueCapacity:任务队列容量(阻塞队列)

当核心线程数达到最大时,新任务会放在队列中排队等待执行

maxPoolSize:最大线程数

当线程数>=corePoolSize,且任务队列已满时。线程池会创建新线程来处理任务

当线程数=maxPoolSize,且任务队列已满时,线程池会拒绝处理任务而抛出异常

keepAliveTime:线程空闲时间

当线程空闲时间达到keepAliveTime时,线程会退出,直到线程数量=corePoolSize

如果allowCoreThreadTimeout=true,则会直到线程数量=0

allowCoreThreadTimeout:允许核心线程超时

rejectedExecutionHandler:任务拒绝处理器

两种情况会拒绝处理任务:

当线程数已经达到maxPoolSize,切队列已满,会拒绝新任务

当线程池被调用shutdown()后,会等待线程池里的任务执行完毕,再shutdown。如果在调用shutdown()和线程池真正shutdown之间提交任务,会拒绝新任务

线程池会调用rejectedExecutionHandler来处理这个任务。如果没有设置默认是 AbortPolicy,会抛出异常

ThreadPoolExecutor类有几个内部实现类来处理这类情况:

AbortPolicy 丢弃任务,抛运行时异常

CallerRunsPolicy 执行任务

DiscardPolicy 忽视,什么都不会发生

DiscardOldestPolicy 从队列中踢出最先进入队列(最后一个执行)的任务

实现RejectedExecutionHandler接口,可自定义处理器

二、ThreadPoolExecutor执行顺序

线程池按以下行为执行任务

(1)当线程数小于核心线程数时,创建线程。

(2)当线程数大于等于核心线程数,且任务队列未满时,将任务放入任务队列。

(3)当线程数大于等于核心线程数,且任务队列已满

1)若线程数小于最大线程数,创建线程

2)若线程数等于最大线程数,抛出异常,拒绝任务

三、如何设置参数

默认值

corePoolSize=1

queueCapacity=Integer.MAX_VALUE

maxPoolSize=Integer.MAX_VALUE

keepAliveTime=60s

allowCoreThreadTimeout=false

rejectedExecutionHandler=AbortPolicy()

如何来设置

需要根据几个值来决定

tasks :每秒的任务数,假设为500~1000

taskcost:每个任务花费时间,假设为0.1s

responsetime:系统允许容忍的最大响应时间,假设为1s

做几个计算

corePoolSize = 每秒需要多少个线程处理?

threadcount = tasks/(1/taskcost) =tasks*taskcout = (500~1000)*0.1 = 50~100 个线程。corePoolSize设置应该大于50

根据8020原则,如果80%的每秒任务数小于800,那么corePoolSize设置为80即可

queueCapacity = (coreSizePool/taskcost)*responsetime

计算可得 queueCapacity = 80/0.1*1 = 80。意思是队列里的线程可以等待1s,超过了的需要新开线程来执行

切记不能设置为Integer.MAX_VALUE,这样队列会很大,线程数只会保持在corePoolSize大小,当任务陡增时,不能新开线程来执行,响应时间会随之陡增。

maxPoolSize = (max(tasks)- queueCapacity)/(1/taskcost)

计算可得 maxPoolSize = (1000-80)/10 = 92

(最大任务数-队列容量)/每个线程每秒处理能力 = 最大线程数

rejectedExecutionHandler:根据具体情况来决定,任务不重要可丢弃,任务重要则要利用一些缓冲机制来处理

keepAliveTime和allowCoreThreadTimeout采用默认通常能满足

以上都是理想值,实际情况下要根据机器性能来决定。如果在未达到最大线程数的情况机器cpu load已经满了,则需要通过升级硬件和优化代码,降低taskcost来处理。

二、线程池icon大小如何设置?

线程池的icon大小可以根据实际需要进行设置,一般情况下,建议将icon大小设置为合适的尺寸,以保证在不同的设备上能够正常显示。具体设置方法如下:

1. 在设计icon时,可以选择合适的图形软件,例如Photoshop、Illustrator等,打开图像文件进行编辑。

2. 根据实际需要,设置icon的尺寸,一般情况下,建议将icon的大小设置为32*32或64*64等常见的尺寸。

3. 进行图像设计,选择合适的颜色、字体、图形等元素,完成icon的设计。

4. 导出icon文件,可以选择png、jpg等格式,保存到本地。

5. 在应用程序中,将icon文件导入到对应的位置,设置icon的显示大小和位置,即可在应用程序中显示出来。

需要注意的是,在设置icon大小时,应该考虑到不同设备的屏幕分辨率和显示效果,避免出现过大或过小的情况。

三、tomcat线程池大小多少合适?

根据机器大小决定设置多少。在tomcat虚拟内存为2G,建议设置最大线程为500~600,可支持最大并发量为500~600

在tomcat虚拟内存为4G,建议设置最大线程为600~700,可支持最大并发量为600~700

如果需要达到自身业务系统的最优配置,还是需要根据自身业务系统的场景进行逐步压力实测,再根据结果进行线程数的上调或下调。配置决定多少合适

四、如何修改weblogic默认线程池大小?

也就是说,一个用户登陆应用系统进行某操作,则WebLogic将从weblogic.kernel.default中分配一个线程给该用户。默认情况下,这个参数值是40。比如对大的企业应用,同一时间登陆操作系统的用户非常多,则40个线程就显得太少了

五、php多线程教程?

PHP+shell实现多线程的方法

先写个简单的php代码,这里为了让脚本执行时间更长,方便看效果,sleep一下,呵呵!先看下test.php的代码:ls

PHP代码:

for ($i=0;$i<10;$i++) {

echo $i;

sleep(10);

}

?>

在看下shell脚本的代码,非常简单

#!/bin/bash

for i in 1 2 3 4 5 6 7 8 9 10

do

/usr/bin/php -q /var/www/html/test.php &

done

注意到在请求php代码的那行有一个&符号吗,这个是关键,不加的话是不能进行多线程的,&表示讲服务推送到后台执行,因此,在 shell的每次的循环中不必等php的代码全部执行完在请求下一个文件,而是同时进行的,这样就实现了多线程,下面运行下shell看下效果,这里你将 看到10个test.php进程再跑,再利用linux的定时器,定时请求这个shell,在处理一些需要多线程的任务,例如,批量下载时,非常好用!

php中用WEB服务器实现多线程

假设我们现在运行的是a.php这个文件. 但是我在程序中又请求WEB服务器运行另一个b.php,那么这两个文件将是同时执行的.(PS: 一个链接请求发送之后, WEB服务器就会执行它, 而不管客户端是否已经退出)

有些时候, 我们想运行的不是另一个文件, 而是本文件中的一部分代码.该怎么办呢?

其实可是通过参数来控制a.php来运行哪一段程序.

下面看一个例子:

//a.php,b.php

PHP代码:--------------------------------------------------------------------------------

function runThread()

{

$fp = fsockopen('localhost', 80, $errno, $errmsg);

fputs($fp, "GET /b.php?act=b\r\n\r\n"); //这里的第二个参数是HTTP协议中规定的请求头

//不明白的请看RFC中的定义

fclose($fp);

}

function a()

{

$fp = fopen('result_a.log', 'w');

fputs($fp, 'Set in ' . Date('h:i:s', time()) . (double)microtime() . "\r\n");

fclose($fp);

}

function b()

{

$fp = fopen('result_b.log', 'w');

fputs($fp, 'Set in ' . Date('h:i:s', time()) . (double)microtime() . "\r\n");

fclose($fp);

}

if(!isset($_GET['act'])) $_GET['act'] = 'a';

if($_GET['act'] == 'a')

{

runThread();

a();

}

else if($_GET['act'] == 'b') b();

?>

--------------------------------------------------------------------------------

打开result_a.log 和 result_b.log 比较一下两个文件的中访问的时间. 大家会发现, 这两个的确是在不同线程中运行的.有些时间完全一样.

上面只是一个简单的例子, 大家可以改进成其它形式.

既然PHP中也能多线程了, 那么问题也来了, 那就是同步的问题. 我们知道 PHP本身是不支持多线程的. 所以更不会有什么像Java 中synchronize的方法了. 那我们该如何做呢.

1. 尽量不访问同一个资源. 以避免冲突. 但是可以同时像数据库操作. 因为数据库是支持并发操作的. 所以在多线程的PHP中不要向同一个文件中写入数据. 如果必须要写的话, 用别的方法进行同步.. 如调用 flock对文件进行加锁等. 或建立临时文件并在另外的线程中等待这个文件的消失 while(file_exits('xxx')); 这样就等于这个临时文件存在时, 表示其实线程正在操作

如果没有了这个文件, 说明其它线程已经释放了这个.

2. 尽量不要从runThread在执行fputs后取这个socket中读取数据. 因为要实现多线程, 需要的用非阻塞模式. 即在像fgets这样的函数时立即返回.. 所以读写数据就会出问题. 如果使用阻塞模式的话, 程序就不算是多线程了. 他要等上面的返回才执行下面的程序. 所以如果需要交换数据最后利用外面文件或数据中完成. 实在想要的话就用socket_set_nonblock($fp) 来实现.

说了这么多, 倒底这个有没有实际的意义呢? 在什么时候需要这种用这种方法呢 ?

答案是肯定的. 大家知道. 在一个不断读取网络资源的应用中, 网络的速度是瓶颈. 如果采多这种形式就可以同时以多个线程对不同的页面进行读取.

本人做的一个能从8848、soaso这些商城网站搜索信息的程序。还有一个从阿里巴巴网站上读取商业信息和公司目录的程序也用到了此技术。 因为这两个程序都是要不断的链接它们的服务器读取信息并保存到数据库。 利用此技术正好消除了在等待响应时的瓶颈。

php模拟实现多线程的三种方法

PHP语言本身是不支持多线程的. 总结了一下网上关于PHP模拟多线程的方法, 总的来说, 都是利用了PHP的好伙伴们本身所具有的多线程能力. PHP的好伙伴指的就是LINUX和APACHE啦, LAMP嘛.

另外, 既然是模拟的, 就不是真正的多线程. 其实只是多进程. 进程和线程是两个不同的概念. 好了, 以下方法都是从网上找来的.

1. 利用LINUX操作系统

for ($i=0;$i<10;$i++) {

echo $i;

sleep(5);

}

?>

上面存成test.php, 然后写一段SHELL代码

#!/bin/bash

for i in 1 2 3 4 5 6 7 8 9 10

do

php -q test.php &

done

2. 利用fork子进程(其实同样是利用LINUX操作系统)

declare(ticks=1);

$bWaitFlag = FALSE; /// 是否等待进程结束

$intNum = 10; /// 进程总数

$pids = array(); /// 进程PID数组

echo ("Startn");

for($i = 0; $i < $intNum; $i++) {

$pids[$i] = pcntl_fork();/// 产生子进程,而且从当前行之下开试运行代码,而且不继承父进程的数据信息

if(!$pids[$i]) {

// 子进程进程代码段_Start

$str="";

sleep(5+$i);

for ($j=0;$j<$i;$j++) {$str.="*";}

echo "$i -> " . time() . " $str n";

exit();

// 子进程进程代码段_End

}

}

if ($bWaitFlag)

{

for($i = 0; $i < $intNum; $i++) {

pcntl_waitpid($pids[$i], $status, WUNTRACED);

echo "wait $i -> " . time() . "n";

}

}

echo ("Endn");

?>

3. 利用WEB SERVER, PHP不支持多线程, APACHE可是支持的, 呵呵.

假设我们现在运行的是a.php这个文档. 但是我在程式中又请求WEB服务器运行另一个b.php

那么这两个文档将是同时执行的.(代码同上)

当然啦,也可以把需要多线程处理的部分交给JAVA去处理, 然后在PHP里调用, 哈哈.

system('java multiThread.java');

?>

扩展资料:PHP即“超文本预处理器”,是一种通用开源脚本语言。PHP是在服务器端执行的脚本语言,与C语言类似,是常用的网站编程语言。PHP独特的语法混合了C、Java、Perl以及 PHP 自创的语法。利于学习,使用广泛,主要适用于Web开发领域。

六、tomcat线程池和普通线程池区别?

1. 明确结论:tomcat线程池和普通线程池的主要区别在于请求的获取方式和线程池的生命周期管理方式。tomcat线程池通过容器来管理线程池的生命周期,并使用基于FIFO的请求队列进行请求的获取,而普通线程池则直接将任务提交到线程池中,使用基于优先级的任务队列进行请求的获取。

2. 解释原因:tomcat线程池使用容器管理线程池的生命周期,可以避免在多线程环境下线程池的不稳定性和死锁等问题。而基于FIFO的请求队列可以保证请求的公平性,避免线程饥饿的出现。普通线程池则更加灵活,可以根据业务需求进行定制化的初始化和销毁操作,但同时也存在可能因为线程池的不稳定性而导致服务崩溃的风险。基于优先级的任务队列则能够使得任务的按照优先级依次执行。

3. 内容延伸:另外,tomcat线程池还支持基于JMX的线程池状态查询和修改,可以通过JMX进行线程池的性能监控和动态调整,而普通线程池则需要手动实现该功能,增加了开发者的负担。同时,tomcat线程池还支持异步请求处理,可以通过AioEndpoint的方式来支持基于NIO的异步请求处理流程,提高系统的性能和吞吐量。而普通线程池则需要手动进行任务的IO操作,对于大规模IO密集型应用而言,效率较低。

4. 具体步骤:在使用tomcat线程池时,可以通过修改server.xml配置文件中的Connector元素来对线程池进行配置,例如修改其maxThreads和minSpareThreads属性等。在使用普通线程池时,则需要自行实现线程池的初始化、销毁、任务提交和任务队列等相关逻辑。可以选择使用Java中内置的线程池工具类,也可以根据业务需求进行定制化的开发。

七、php是多线程还是单线程?

单线程的,如果非静态页,你发现当你一个网页没有运行完时另一个网页也打不开

八、Java线程池?

多线程是为了能够让计算机资源合理的分配,对于处理不同的任务创建不同的线程进行处理,但是计算机创建一个线程或者销毁一个线程所花费的也是比较昂贵的,有时候需要同时处理的事情比较多,就需要我们频繁的进行线程的创建和销毁,这样花费的时间也是比较多的。为了解决这一问题,我们就可以引用线程池的概念。

所谓线程池就是将线程集中管理起来,当需要线程的时候,可以从线程池中获取空闲的线程,这样可以减少线程的频繁创建与销毁,节省很大的时间和减少很多不必要的操作。

在java中提供了ThreadPoolExecutor类来进行线程的管理,这个类继承于AbstractExecutorService,而AbstractExecutorService实现了ExecutorService接口,我们可以使用ThreadPoolExecutor来进行线程池的创建。

在ThreadPoolExecutor的构造方法中,有多个参数,可以配置不同的参数来进行优化。这个类的源码构造方法为:

public ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue workQueue, ThreadFactory threadFactory, RejectedExecutionHandler handler)其中每个参数代表的意义分别为:

corePoolSize : 线程池中的核心线程数量,当线程池中当前的线程数小于这个配置的时候,如果有一个新的任务到来,即使线程池中还存在空闲状态的线程,程序也会继续创建一个新的线程放进线程池当中

maximumPoolSize: 线程池中的线程最大数量

keepAliveTime:当线程池中的线程数量大于配置的核心线程数量(corePoolSize)的时候,如果当前有空闲的线程,则当这个空闲线程可以存在的时间,如果在keepAliveTime这个时间点内没有新的任务使用这个线程,那么这个线程将会结束,核心线程不会结束,但是如果配置了allowCoreThreadTimeOut = true,则当空闲时间超过keepAliveTime之后,线程也会被结束调,默认allowCoreThreadTimeOut = false,即表示默认情况下,核心线程会一直存在于线程池当中。

unit : 空闲线程保持连接时间(keepAliveTime)的时间单位

workQueue:阻塞的任务队列,用来保存等待需要执行的任务。

threadFactory :线程工厂,可以根据自己的需求去创建线程的对象,设置线程的名称,优先级等属性信息。

handler:当线程池中存在的线程数超过设置的最大值之后,新的任务就会被拒绝,可以自己定义一个拒绝的策略,当新任务被拒绝之后,就会使用hander方法进行处理。

在java中也提供了Executors工具类,在这个工具类中提供了多个创建线程池的静态方法,其中包含newCachedThreadPool、newFixedThreadPool、newScheduledThreadPool、newSingleThreadExecutor等。但是他们每个方法都是创建了ThreadPoolExecutor对象,不同的是,每个对象的初始 参数值不一样;

九、线程池,怎么停止线程池中的线程?

1.自然终止。

你的线程执行完它启动时运行的方法,就自然终止了。适用于单个或多个一次性任务。如果是多个,这种情况推荐线程池。把任务写成线程池的Task。

2.有个管理线程,去调用工作线程的workingThread.Interrupt()方法。前提是,用一些同步机制防止工作线程的工作做一半被扔那了。

这种办法适用于循环等待某些任务的线程,比如TCPListener的循环Accept的线程或者其它响应消息的线程,或者接收/处理心跳消息的线程。

十、java线程池 中止线程

Java线程池:中止线程的最佳实践

在Java开发中,使用线程池是一种常见且高效的多线程处理方式。然而,对于一些特定场景,在线程池中正确地中止线程却是一项具有挑战性的任务。本文将讨论如何在Java线程池中有效地中止线程,以及一些最佳实践。

线程池和线程中止的重要性

首先,让我们简要回顾一下线程池的概念。线程池是一种重用线程的机制,可以减少线程创建和销毁的开销,提高程序的性能和响应速度。在Java中,线程池由java.util.concurrent包提供,通过Executor框架实现。

然而,当涉及到线程中止时,有些开发者可能会遇到困难。错误地中止线程可能导致资源泄漏或程序运行异常,因此确保线程在正确的时机和方式下被中止非常重要。

正确中止线程的方法

在Java中,线程的中止通常通过设置一个标志来实现。下面是一个通用的示例代码:

volatile boolean isRunning = true; public void run() { while(isRunning) { // 执行线程任务 } } public void stopThread() { isRunning = false; }

在这个示例中,通过设置isRunning标志来控制线程是否继续执行。当调用stopThread()方法时,线程将在下一个循环迭代中退出,从而实现线程的中止。

Java线程池的中止策略

对于线程池中的线程,中止的方法与单独线程类似,但需要更加谨慎。下面是一种推荐的线程池中止策略:

  1. 使用ExecutorService接口:线程池通常是通过Executor框架创建和管理的,因此使用ExecutorService接口来操作线程池是最佳实践。
  2. 提交中止任务:为线程池中的每个线程提交一个中止任务,确保线程在任务完成后能够正确退出。
  3. 优雅地等待线程结束:在任务提交后,调用ExecutorServiceawaitTermination()方法来等待所有线程结束,以确保线程池完全关闭。

示例代码

下面是一个简单的Java线程池中止示例:


ExecutorService executor = Executors.newFixedThreadPool(5);

for(int i=0; i<10; i++) {
    executor.submit(() -> {
        System.out.println("Task running");
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    });
}

// 提交中止任务
executor.shutdown();

// 等待所有线程结束
try {
    executor.awaitTermination(5, TimeUnit.SECONDS);
} catch (InterruptedException e) {
    e.printStackTrace();
}

结论

在Java开发中,正确地中止线程对于程序的稳定性和性能至关重要。通过使用标志位设置、合适的中止策略以及线程池的管理方法,可以有效地中止线程并避免潜在的问题。

希望本文提供的内容能够帮助您更好地理解Java线程池中止的方法,同时也提高您的多线程编程水平。

顶一下
(0)
0%
踩一下
(0)
0%
相关评论
我要评论
用户名: 验证码:点击我更换图片

网站地图 (共30个专题189790篇文章)

返回首页