原文链接:http://www.iteye.com/topic/366591
1:Executor类
子接口:ExecutorService,ScheduledExecutorService
执行已提交的Runnable任务对象。该接口将任务的提交和任务的运行相分离。通常使用该类而不是显示创建线程。
通常使用子接口ExecutorService来提交但返回值和不带返回值的任务,也可以执行关闭方法shutdown,拒接结束新的任务
2:Executors类
个人感觉主要使用该类返回的各种实力来创建线程
public class LiftOff implements Runnable{
private int countDown = 10;
private static int taskCount = 0;
private final int id=taskCount++;
public LiftOff() {}
public LiftOff(int countDown) {
this.countDown = countDown;
}
public static void main(String[] args) {
new Thread(new LiftOff()).start();
}
@Override
public void run() {
while(countDown-- > 0) {
System.out.println(status());
Thread.yield();
}
}
public String status() {
return "#" + id + "(" + (countDown > 0 ? countDown : "LiftOff!") + ").";
}
}
public class CachedThreadPool {
public static void main(String[] args) {
ExecutorService exe = Executors.newCachedThreadPool();
// ExecutorService exe = Executors.newFixedThreadPool(5);
// ExecutorService exe = Executors.newSingleThreadExecutor();
for(int i=0;i<5;i++) {
exe.execute(new LiftOff());
}
//防止新的任务提交给该Executor
exe.shutdown();
//抛出java.util.concurrent.RejectedExecutionException异常
exe.execute(new LiftOff());
}
}
3:Callable接口
该接口包含一个call()方法,用来代替runnable接口,在完成任务时返回一个值
4:Future接口
主要通过get()方法,来返回异步计算的结果
public class CallableDemo {
public static void main(String[] args) {
ExecutorService exe = Executors.newCachedThreadPool();
ArrayList<Future<String>> results = new ArrayList<Future<String>>();
for(int i=0;i<10;i++) {
results.add(exe.submit(new TaskWithResult(i)));
}
for (Future<String> future : results) {
try {
//如果任务已完成,则返回 true。 可能由于正常终止、异常或取消而完成,
//在所有这些情况中,此方法都将返回 true。
if(future.isDone()) {
System.out.println(future.get());
//第一个参数:等待的时间 第二个参数:单位
System.out.println(future.get(1, TimeUnit.SECONDS));
}
if(future.isCancelled()) {
System.out.println("cancled.....");
}
} catch (InterruptedException e) {
e.printStackTrace();
} catch (ExecutionException e) {
e.printStackTrace();
} catch (TimeoutException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}
class TaskWithResult implements Callable<String> {
private int id;
public TaskWithResult(int id) {
this.id=id;
}
public String call() throws Exception {
return "result of TaskWithResult " + id;
}
}
分享到:
相关推荐
在项目的性能测试过程中,确定一个实际系统的并发用户数是非常重要的步骤。并发用户数是指在同一时间段内访问系统的用户数量,影响着系统的性能和稳定性。本文将详细介绍如何确定一个实际系统的并发用户数。 什么是...
系统的讲解了java高并发的实现,建立高可用的应用程序。
步骤一:设置进程池 在 IIS 中,进程池是指应用程序池的队列长度,用于限制同时访问的用户数量。默认情况下,IIS 的进程池队列长度为 5000,显然不足以满足高并发的需求。为了提高 IIS 的并发访问量,需要将进程池...
Java 并发工具类是 Java 并发编程中的一种重要工具,用于协调线程之间的并发执行。 Java 并发工具类中有很多种,今天我们主要介绍四种:CyclicBarrier、CountDownLatch、Semaphore 和 Exchanger。 一、...
并发编程之深入理解JMM&并发三大特性
在现代互联网服务中,高并发访问处理能力是衡量一个Web服务器性能的关键因素之一。Nginx作为一款广泛应用的反向代理和负载均衡服务器,其高效的性能和低资源消耗使其成为处理高并发场景的首选。本文将详细探讨如何...
一、测试目的 1、测试典型页面能支持的最大并发用户数。 2、测试典型页面在响应时间为10s 的时间内,能支持的最大并发数。 二、选择的典型页面及并发点 1、登录首页http://192.168.1.10。并发点:同时打开这个链接。...
在 Java 并发编程中,多线程协作机制是非常重要的一部分。多线程协作机制是指在多线程编程中,多个线程之间如何协作、同步和通信,以达到共同完成某个任务的目的。Java 提供了多种多线程协作机制,包括...
实验一体验Nachos下的并发程序设计 本实验的目的是对Nachos进行熟悉,并初步体验Nachos下的并发程序设计。Nachos是一种操作系统,可以运行在X86架构的计算机上。它提供了一个简洁的接口,允许用户编写并发程序。 ...
并发控制是数据库管理系统中的一项重要机制,其任务是对并发操作进行正确调度,保证事务的隔离性和数据库的一致性。事务是并发控制的基本单位。并发控制机制的目标是确保多个事务的并发执行不影响数据库的一致性和...
"用户并发数和在线数和用户总数的关系" 在讨论用户并发数和在线数的关系之前,我们首先需要了解什么是“系统用户数”、“同时在线用户数”和“并发用户数”。 系统用户数是指可能使用该系统的用户总数。在我们的...
TCP 服务器在监听端口前初始化一个 socket,每有一个新的连接,就新建一个 socket,因此当 TCP 服务器面对高并发请求时,实际上有多个 socket,也就是有多个文件描述符。Epoll、select 适用于这种模式。但是 UDP ...
│ 高并发编程第一阶段01讲、课程大纲及主要内容介绍.wmv │ 高并发编程第一阶段02讲、简单介绍什么是线程.wmv │ 高并发编程第一阶段03讲、创建并启动线程.mp4 │ 高并发编程第一阶段04讲、线程生命周期以及...
1. 聊聊并发(一)深入分析Volatile的实现原理 2. 聊聊并发(二)Java SE1.6中的Synchronized 3. 聊聊并发(三)Java线程池的分析和使用 4. 聊聊并发(四)深入分析ConcurrentHashMap 5. 聊聊并发(五)原子操作的...
性能之并发用户数的计算是一个重要的性能测试指标,它可以帮助开发者和测试者评估系统的性能和承载能力。计算并发用户数可以使用多种方法,包括经典公式、通用公式、根据 PV 计算公式、根据 TPS 估计、根据系统用户...
理解Go语言如何解决并发难以编写正确这一根本问题。 学习并发与并行的关键性区别。 深入到Go语言的内存同步原语。 利用这些模式中的原语编写可维护的并发代码。 将模式组合成为一系列的实践,使你能够编写大规模...
该程序是为自己项目写的一个测试性能的小程序。 主要通过对服务器下载文件的并发响应进行统计。 使用多线程对服务器提供的链接地址下载文件, 能统计出并发情况下的下载速度,请不要开辟开多线程,以免导致服务器受...
Java高并发编程是Java开发中不可或缺的一部分,尤其在大规模分布式系统设计中,处理高并发问题至关重要。本篇文章将从基础知识出发,对高并发的核心概念进行深入解析,为后续的学习打下坚实的基础。 首先,我们要...
nachos实验一体验Nachos下的并发程序设计 代码
Joseph Bowbeer是一个Java ME专家,他对并发编程的兴趣始于Apollo计算机时代。David Holmes是《The Java Programming Language》一书的合著者,任职于Sun公司。Joshua Bloch是Google公司的首席Java架构师,...