`
softlife
  • 浏览: 109140 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

线程池的使用

    博客分类:
  • Java
 
阅读更多
package com.pool;

import java.util.LinkedList;
import java.util.Queue;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.Executors;
import java.util.concurrent.RejectedExecutionHandler;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ScheduledFuture;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

/**
 * 线程队列管理
 * 
 */
@SuppressWarnings("unchecked")
public class ThreadPoolManager {
	private static ThreadPoolManager me = new ThreadPoolManager();
	// 线程池维护线程的最少数量
	private final static int CORE_POOL_SIZE = 3;
	// 线程池维护线程的最大数量
	private final static int MAX_POOL_SIZE = 100;
	// 线程池维护线程所允许的空闲时间
	private final static int KEEP_ALIVE_TIME = 0;
	// 线程池所使用的缓冲队列大小,>1000的线程走调度
	private final static int WORK_QUEUE_SIZE = 1000;

	/** 通知队列 **/
	Queue<Runnable> QUEUES = new LinkedList<Runnable>();

	public static ThreadPoolManager getInstance() {
		return me;
	}

	final RejectedExecutionHandler handler = new RejectedExecutionHandler() {
		public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
			QUEUES.offer(r);
		}
	};

	// 管理线程池
	final ThreadPoolExecutor threadPool = new ThreadPoolExecutor(CORE_POOL_SIZE, MAX_POOL_SIZE, KEEP_ALIVE_TIME,
			TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(WORK_QUEUE_SIZE), this.handler);

	// 调度线程池
	final ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);

	// 访问消息缓存的调度线程
	final Runnable accessBufferThread = new Runnable() {
		public void run() {
			if (hasMoreThreads()) {
				System.out.println(QUEUES.size());
				Runnable task = QUEUES.poll();
				threadPool.execute(task);
			}
		}
	};
	//任务调度,超过(MAX_POOL_SIZE+WORK_QUEUE_SIZE)数量的线程,自动走调度执行
	final ScheduledFuture taskHandler = scheduler.scheduleAtFixedRate(accessBufferThread, 0, 10, TimeUnit.SECONDS);
	private ThreadPoolManager() {
			System.out.println("启动线程池...");
	}

	public void addThread(Thread task) {
		threadPool.execute(task);
	}

	private boolean hasMoreThreads() {
		return !QUEUES.isEmpty();
	}

}


package com.pool;

import java.util.Date;
/**
*测试调用代码
**/
public class test {
	
	public static void main(String[] args) {
		
		for (int i = 0; i<= 10000;i++){
			ThreadPoolManager.getInstance().addThread(new Thread(){
				public void run(){
					try {
						System.out.println(new Date());
						Thread.sleep(1000);
					} catch (InterruptedException e) {
						// TODO Auto-generated catch block
						e.printStackTrace();
					}
				}
			});
		}
		
	}

}
分享到:
评论

相关推荐

    java线程池使用后到底要关闭吗

    java线程池使用后到底要关闭吗 java线程池是一种高效的并发编程技术,可以帮助开发者更好地管理线程资源,提高系统的性能和可靠性。然而,在使用java线程池时,一个常见的问题是:使用完线程池后到底要不要关闭?...

    c#线程池使用demo

    在本示例"C#线程池使用demo"中,我们将探讨如何利用线程池来执行任务,以及其背后的原理和最佳实践。 首先,线程池主要由System.Threading命名空间下的ThreadPool类提供。在C#中,我们可以通过以下方式向线程池提交...

    C# 线程池使用示例

    在VS2013环境下,结合控制台窗口,我们可以轻松地实现线程池的使用。下面将详细探讨C#线程池的工作原理、优势以及如何在实际项目中应用。 线程池的基本概念: 线程池是一组预先创建的线程,这些线程由操作系统维护...

    Java线程池使用说明

    使用线程池的好处有很多,比如减少了创建和销毁线程的次数,提高了程序性能;允许线程被重复利用,执行多个任务;可以根据系统承载能力动态调整线程池大小,避免服务器资源过度消耗。 在Java中,与线程池相关的几个...

    线程池使用demo

    线程池使用的几个demo

    线程池使用基本框架

    线程池使用基本框架,快速掌握线程池技术

    ThreadPoolExecutor的使用和Android常见的4种线程池使用介绍

    ThreadPoolExecutor的使用和Android常见的4种线程池使用介绍

    VB线程池使用

    VB 线程池使用 VB 线程池使用是多线程应用程序中的一种重要概念,它可以有效地改善应用程序的响应时间,减少系统资源的占用,提高系统的性能。在多线程应用程序中,线程池的使用可以解决线程生命周期的开销问题和...

    多线程线程池使用 (C#3.5) 高效

    5. **优化线程池使用** - 避免长时间运行的任务:线程池更适合执行短时间的任务,长时间运行的任务应使用单独的线程。 - 合理设置线程池大小:根据系统资源和任务特性动态调整线程池大小,防止过度消耗资源或导致...

    线程池使用Demo

    线程池是Java并发编程中的重要概念,它是一种线程使用模式,用于高效地管理和执行大量并发任务。在Java中,我们主要通过`java.util.concurrent`包中的`ExecutorService`接口及其实现类来创建和管理线程池。线程池的...

    线程池使用实例,一个简单的使用线程池的例子

    线程池使用实例,一个简单的使用线程池的例子

    如何使用线程池

    以下示例显示如何使用线程池。首先创建 ManualResetEvent 对象,此对象使程序能够知道线程池何时运行完所有的工作项。接着,尝试向线程池添加一个线程。如果添加成功,则添加其余的线程(本例中为 4 个)。然后...

    linux线程池使用(动态调整).rar

    linux线程池使用(动态调整).rar

    VC简单的线程池使用实例

    1.线程池管理器(ThreadPoolManager):用于创建并管理线程池 2.工作线程(WorkThread): 线程池中线程 3.任务接口(Task):每个任务必须实现的接口,以供工作线程调度任务的执行。 4.任务队列:用于存放没有处理的...

    线程池使用示例(含源代码)

    线程池是多线程编程中的一个重要概念,它是一种线程使用模式,通过维护一组可重用线程来提高程序的性能和响应速度。在Java中,我们可以使用`java.util.concurrent`包下的`ExecutorService`接口及其实现类,如`...

    socket编程 使用select与线程池

    在本主题中,我们将深入探讨如何使用`select`机制和线程池来构建高效的TCP、UDP服务器,以及客户端的实现。 首先,TCP(传输控制协议)是一种面向连接的、可靠的、基于字节流的传输层通信协议,而UDP(用户数据报...

    线程池的使用介绍Demo,简单明了。

    线程池在Android开发中...合理的线程池使用不仅可以提高程序的并发能力,还能避免过度创建线程带来的性能开销。在实际开发中,我们需要根据应用的具体场景选择合适的线程池类型和参数,以实现最佳的性能和资源利用率。

    线程池管理多线程上传

    线程池管理和多线程上传是并发编程中的一个重要实践,特别是在大数据传输和网络服务中。在Java等编程语言中,线程池通过有效地管理和复用线程资源,避免了频繁创建和销毁线程带来的开销,提升了系统性能。下面将详细...

    Linux线程池使用.docx

    2. **线程生命周期**:线程池中的线程是后台线程,它们使用默认的堆栈大小和优先级运行。如果线程等待某个事件,线程池会调度其他线程保持CPU繁忙。线程数量不会超过设定的最大值,超过的线程会被放入队列等待。 3. ...

Global site tag (gtag.js) - Google Analytics