语源科技BlogJava-feu yeux

Java中并发环境中的For和ForEach

Lu Han — Wed, 05 Sep 2012 06:09:00 GMT

package creative.air.datastructure.array;

import java.util.ArrayList;

import java.util.concurrent.CountDownLatch;

import java.util.logging.Level;

import java.util.logging.Logger;

public class IterateList {

static final Logger logger = Logger.getLogger(IterateList.class.getName());

static ArrayList list = new ArrayList();

static final CountDownLatch gateLatch1 = new CountDownLatch(1);

static final CountDownLatch gateLatch2 = new CountDownLatch(1);

public void addMock() {

int top = 0;

while (top < 20) {

list.add(top++);

}

public void iterating1() {

try {

//java.lang.IndexOutOfBoundsException:

//for (int i = 0, len =list.size(); i < len; i++) {

for (int i = 0; i < list.size(); i++) {

if (i == 3) {

gateLatch1.countDown();

}

logger.log(Level.INFO, "i={0} list({1})='{'{2}'}'", new Object[]{i, i, list.get(i)});

}

} catch (Exception e) {

logger.log(Level.SEVERE, null, e);

}

public void iterating2() {

try {

int i = 0;

//java.util.ConcurrentModificationException:

for (int n : list) {

if (i == 3) {

gateLatch2.countDown();

}

logger.log(Level.INFO, "i={0} list({1})='{'{2}'}'", new Object[]{i, i, n});

i++;

}

} catch (Exception e) {

logger.log(Level.SEVERE, null, e);

}

public static void main(String[] ss) {

IterateList test = new IterateList();

Thread remover1 = new Thread(new Runnable() {

@Override

public void run() {

try {

gateLatch1.await();

} catch (InterruptedException ex) {

logger.log(Level.SEVERE, null, ex);

}

if (!list.isEmpty()) {

list.remove(0);

}

logger.log(Level.INFO, "list size:{0}", list.size());

}

});

Thread remover2 = new Thread(new Runnable() {

@Override

public void run() {

try {

gateLatch2.await();

} catch (InterruptedException ex) {

logger.log(Level.SEVERE, null, ex);

}

if (!list.isEmpty()) {

list.remove(0);

}

logger.log(Level.INFO, "list size:{0}", list.size());

}

});

remover1.start();

remover2.start();

test.addMock();

test.iterating1();

test.iterating2();

}

Lu Han 2012-09-05 14:09 发表评论

事务简述

Lu Han — Wed, 25 Apr 2012 02:45:00 GMT

ACID
atomicity [,ætə'misəti] 原子性
consistency [kən'sistənsi] 一致性
isolation ['aisə'leiʃən] 隔离性
durability [,djuərə'biləti] 持久性

InnoDB
QPS Question Per Second
TPS Transaction Per Second=(com_commit+com_rollback)/time

隔离级别	更新丢失	脏读取	重复读取	幻读
未授权读取READ-UNCOMMITTED	N	Y	Y	Y
授权读取READ-COMMITTED	N	N	Y	Y
可重复读取REPEATABLE-READ	N	N	N	Y
串行SERIALIZABLE	N	N	N	N

数据库并发操作存在的异常情况：

1.更新丢失（LostUpdate）：

A和B事务并发执行，A事务执行更新后，提交；B事务在A事务更新后，B事务结束前也做了对该行数据的更新操作，然后回滚，则两次更新操作都丢失了。

第一类丢失更新(回滚丢失，Lost update)。

在事务A期间，事务B对数据进行了更新；在事务A撤销之后，覆盖了事务B已经提交的数据。

SQL92没有定义这种现象，标准定义的所有隔离界别都不允许第一类丢失更新发生。

第二类丢失更新(覆盖丢失/两次更新问题，Second lost update)。

在事务A期间，事务B对数据进行了更新；在事务A提交之后，覆盖了事务B已经提交的数据。

第二类丢失更新，实际上和不可重复读是同一种问题。

2.脏读取（DirtyReads）：

A和B事务并发执行，B事务执行更新后，A事务查询B事务没有提交的数据，B事务回滚，则A事务得到的数据不是数据库中的真实数据。也就是脏数据，即和数据库中不一致的数据。

3.不可重复读取（Non-repeatableReads）：

A和B事务并发执行，A事务查询数据，然后B事务更新该数据并提交，A再次查询该数据时，发现该数据变化了。

4.幻读（PhantomReads）：也称为幻像（幻影）。

A和B事务并发执行，A事务查询数据，B事务插入或者删除数据并提交，A事务再次查询发现,结果集中,有以前没有的数据或者以前有的数据消失了。

为了避免上面出现几种情况在标准SQL规范中定义了4个事务隔离级别，不同隔离级别对事务处理不同。

1. READ-UNCOMMITTED未授权读取/未提交读

允许脏读取但不允许更新丢失。

如果一个事务已经开始写数据，则另外一个事务不允许同时进行写操作，但允许其他事务读此行数据。通过“排他写锁”实现。

2. READ-COMMITTED授权读取/提交读

允许不可重复读取但不允许脏读取。

更新语句提交以后别的事务才能读到这个改变。读取数据的事务允许其他事务继续访问该行数据，但是未提交的写事务将会禁止其他事务访问该行。通过“瞬间共享读锁”和“排他写锁”实现，

在此隔离级下，SELECT命令不会返回尚未提交（Committed）的数据，也不能返回脏数据。

3. REPEATABLE-READ可重复读取

禁止不可重复读取和脏读取。但是有时可能出现幻影数据

在同一个事务里面先后执行同一个查询语句的时候，确保得到的结果是一样的。读取数据的事务将会禁止写事务（但允许读事务），写事务则禁止任何其他事务。通过“共享读锁”和“排他写锁”实现，

在此隔离级下，用SELECT命令读取的数据在整个命令执行过程中不会被更改。此选项会影响系统的效能，非必要情况最好不用此隔离级。

4. SERIALIZABLE串行/可串行读。

事务只能一个接着一个地执行，但不能并发执行。如果仅仅通过“行级锁”是无法实现事务序列化的，必须通过其他机制保证新插入的数据不会被刚执行查询操作事务访问到。

Lu Han 2012-04-25 10:45 发表评论

Java安全传输实践2

Lu Han — Fri, 04 Nov 2011 20:27:00 GMT

证书概述：
ICM服务器证书由中间CA签发中间CA由CA签发
UCGW客户端证书由中间CA签发中间CA由CA签发

证书签发过程：
创建ICM自签证书

keytool -genkey -dname "CN=mars_icm, OU=rv, O=rcd, L=ZB, ST=bj, C=China" -alias icm -keyalg RSA -keystore temp/iview.keystore -keypass 111111 -storepass 111111 -validity 60

keytool -certreq -alias icm -keypass 111111 -file "temp/icm.self.csr" -keystore "temp/iview.keystore" -storepass 111111

keytool -export -alias icm -keystore temp/iview.keystore -storepass 111111 -rfc -file temp/icm.self.cer

创建UCGW自签证书

keytool -genkey -dname "CN=mars_UCGW, OU=rv, O=rcd, L=ZB, ST=bj, C=China" -alias ucgw -keyalg RSA -keystore temp/ucgw.keystore -keypass 111111 -storepass 111111 -validity 60

keytool -certreq -alias ucgw -keypass 111111 -file "temp/ucgw.self.csr" -keystore "temp/ucgw.keystore" -storepass 111111

keytool -export -alias ucgw -keystore temp/ucgw.keystore -storepass 111111 -rfc -file temp/ucgw.self.cer

创建中间CA自签证书

keytool -genkey -dname "CN=mars_inter, OU=rv, O=rcd, L=ZB, ST=bj, C=China" -alias intermediary -keyalg RSA -keystore temp/inter.keystore -keypass 111111 -storepass 111111 -validity 60

keytool -certreq -alias intermediary -keypass 111111 -file "temp/inter.self.csr" -keystore "temp/inter.keystore" -storepass 111111

keytool -export -alias intermediary -keystore temp/inter.keystore -storepass 111111 -rfc -file temp/inter.self.cer

创建CA证书

keytool -genkey -dname "CN=mars_ca, OU=rv, O=rcd, L=ZB, ST=bj, C=China" -alias root -keyalg RSA -keystore temp/ca--ca.keystore -keypass 111111 -storepass 111111 -validity 60

keytool -certreq -alias root -keypass 111111 -file "temp/root.csr" -keystore "temp/ca--ca.keystore" -storepass 111111

keytool -export -alias root -keystore temp/ca--ca.keystore -storepass 111111 -rfc -file temp/root.cer

CA签发中间CA证书

keytool -export -alias ca_signed -keystore temp/ca--ca_sign.keystore -storepass 111111 -rfc -file temp/inter.cer

验证中间CA证书

It is signed by the CA

导入中间CA的KeyStore

keytool -importcert -noprompt -trustcacerts -alias root -file temp/root.cer -keystore temp/inter.keystore -storepass 111111 -keypass 111111

keytool -importcert -noprompt -alias intermediary -file temp/inter.cer -keystore temp/inter.keystore -storepass 111111

中间CA签发icm证书

keytool -export -alias inter_signed -keystore temp/ca--ca_sign.keystore -storepass 111111 -rfc -file temp/icm.signed.cer

中间CA签发ucgw证书

keytool -export -alias inter_signed -keystore temp/ca--ca_sign.keystore -storepass 111111 -rfc -file temp/ucgw.signed.cer

验证ICM证书

It is signed by the CA

验证UCGW证书

It is signed by the CA

导入ICM的KeyStore

keytool -importcert -noprompt -trustcacerts -alias root -file temp/root.cer -keystore temp/iview.keystore -storepass 111111 -keypass 111111

keytool -importcert -noprompt -trustcacerts -alias intermediary -file temp/inter.cer -keystore temp/iview.keystore -storepass 111111 -keypass 111111

keytool -importcert -noprompt -alias icm -file temp/icm.signed.cer -keystore temp/iview.keystore -storepass 111111

导入UCGW的KeyStore

keytool -importcert -noprompt -trustcacerts -alias root -file temp/root.cer -keystore temp/ucgw.keystore -storepass 111111 -keypass 111111

keytool -importcert -noprompt -trustcacerts -alias intermediary -file temp/inter.cer -keystore temp/ucgw.keystore -storepass 111111 -keypass 111111

keytool -importcert -noprompt -alias ucgw -file temp/ucgw.signed.cer -keystore temp/ucgw.keystore -storepass 111111

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

keytool -list -keystore temp/ca--ca.keystore -storepass 111111

...

root, 2011-11-5, PrivateKeyEntry,

认证指纹 (MD5)： 49:44:8A:79:3C:62:ED:66:AA:20:D6:BF:65:3E:23:C4

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

keytool -list -keystore temp/inter.keystore -storepass 111111

...

root, 2011-11-5, trustedCertEntry,

认证指纹 (MD5)： 49:44:8A:79:3C:62:ED:66:AA:20:D6:BF:65:3E:23:C4

intermediary, 2011-11-5, PrivateKeyEntry,

认证指纹 (MD5)： 23:6C:C0:46:67:CF:9E:4E:EF:A9:74:95:AB:EE:37:21

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

keytool -list -v -keystore temp/iview.keystore -storepass 111111

...

您的 keystore 包含 3 输入

别名名称： root

创建日期： 2011-11-5

输入类型： trustedCertEntry

所有者:CN=mars_ca, OU=rv, O=rcd, L=ZB, ST=bj, C=China

签发人:CN=mars_ca, OU=rv, O=rcd, L=ZB, ST=bj, C=China

序列号:4eb449c5

有效期: Sat Nov 05 04:23:33 CST 2011 至Wed Jan 04 04:23:33 CST 2012

证书指纹:

MD5:49:44:8A:79:3C:62:ED:66:AA:20:D6:BF:65:3E:23:C4

SHA1:EA:92:AE:59:D1:8D:B6:2F:33:B7:65:CC:6E:B0:B5:7D:40:CF:45:BE

签名算法名称:SHA1withRSA

版本: 3

*******************************************

别名名称： intermediary

创建日期： 2011-11-5

输入类型： trustedCertEntry

所有者:CN=mars_inter, OU=rv, O=rcd, L=ZB, ST=bj, C=China

签发人:CN=mars_ca, OU=rv, O=rcd, L=ZB, ST=bj, C=China

序列号:4eb449c7

有效期: Sat Nov 05 04:23:35 CST 2011 至Wed Jan 22 04:23:35 CST 2020

证书指纹:

MD5:23:6C:C0:46:67:CF:9E:4E:EF:A9:74:95:AB:EE:37:21

SHA1:54:86:85:BC:9C:D5:D2:E8:A4:E6:33:DD:4F:42:87:FB:2A:92:F3:84

签名算法名称:MD5withRSA

版本: 3

*******************************************

别名名称： icm

创建日期： 2011-11-5

项类型: PrivateKeyEntry

认证链长度： 3

认证 [1]:

所有者:CN=mars_icm, OU=rv, O=rcd, L=ZB, ST=bj, C=China

签发人:CN=mars_inter, OU=rv, O=rcd, L=ZB, ST=bj, C=China

序列号:4eb449ca

有效期: Sat Nov 05 04:23:38 CST 2011 至Wed Jan 22 04:23:38 CST 2020

证书指纹:

MD5:95:97:C3:2C:2C:A5:B4:7A:17:EF:98:B7:7B:BC:AE:4A

SHA1:E1:92:F9:79:48:FE:59:AF:3F:85:CE:2A:21:82:AD:B2:00:60:EB:D7

签名算法名称:MD5withRSA

版本: 3

认证 [2]:

所有者:CN=mars_inter, OU=rv, O=rcd, L=ZB, ST=bj, C=China

签发人:CN=mars_ca, OU=rv, O=rcd, L=ZB, ST=bj, C=China

序列号:4eb449c7

有效期: Sat Nov 05 04:23:35 CST 2011 至Wed Jan 22 04:23:35 CST 2020

证书指纹:

MD5:23:6C:C0:46:67:CF:9E:4E:EF:A9:74:95:AB:EE:37:21

SHA1:54:86:85:BC:9C:D5:D2:E8:A4:E6:33:DD:4F:42:87:FB:2A:92:F3:84

签名算法名称:MD5withRSA

版本: 3

认证 [3]:

所有者:CN=mars_ca, OU=rv, O=rcd, L=ZB, ST=bj, C=China

签发人:CN=mars_ca, OU=rv, O=rcd, L=ZB, ST=bj, C=China

序列号:4eb449c5

有效期: Sat Nov 05 04:23:33 CST 2011 至Wed Jan 04 04:23:33 CST 2012

证书指纹:

MD5:49:44:8A:79:3C:62:ED:66:AA:20:D6:BF:65:3E:23:C4

SHA1:EA:92:AE:59:D1:8D:B6:2F:33:B7:65:CC:6E:B0:B5:7D:40:CF:45:BE

签名算法名称:SHA1withRSA

版本: 3

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

keytool -list -v -keystore temp/ucgw.keystore -storepass 111111

...

您的 keystore 包含 3 输入

别名名称： root

创建日期： 2011-11-5

输入类型： trustedCertEntry

所有者:CN=mars_ca, OU=rv, O=rcd, L=ZB, ST=bj, C=China

签发人:CN=mars_ca, OU=rv, O=rcd, L=ZB, ST=bj, C=China

序列号:4eb449c5

有效期: Sat Nov 05 04:23:33 CST 2011 至Wed Jan 04 04:23:33 CST 2012

证书指纹:

MD5:49:44:8A:79:3C:62:ED:66:AA:20:D6:BF:65:3E:23:C4

SHA1:EA:92:AE:59:D1:8D:B6:2F:33:B7:65:CC:6E:B0:B5:7D:40:CF:45:BE

签名算法名称:SHA1withRSA

版本: 3

*******************************************

别名名称： intermediary

创建日期： 2011-11-5

输入类型： trustedCertEntry

所有者:CN=mars_inter, OU=rv, O=rcd, L=ZB, ST=bj, C=China

签发人:CN=mars_ca, OU=rv, O=rcd, L=ZB, ST=bj, C=China

序列号:4eb449c7

有效期: Sat Nov 05 04:23:35 CST 2011 至Wed Jan 22 04:23:35 CST 2020

证书指纹:

MD5:23:6C:C0:46:67:CF:9E:4E:EF:A9:74:95:AB:EE:37:21

SHA1:54:86:85:BC:9C:D5:D2:E8:A4:E6:33:DD:4F:42:87:FB:2A:92:F3:84

签名算法名称:MD5withRSA

版本: 3

*******************************************

别名名称： ucgw

创建日期： 2011-11-5

项类型: PrivateKeyEntry

认证链长度： 3

认证 [1]:

所有者:CN=mars_UCGW, OU=rv, O=rcd, L=ZB, ST=bj, C=China

签发人:CN=mars_inter, OU=rv, O=rcd, L=ZB, ST=bj, C=China

序列号:4eb449cb

有效期: Sat Nov 05 04:23:39 CST 2011 至Wed Jan 22 04:23:39 CST 2020

证书指纹:

MD5:D7:6D:ED:9C:13:B6:79:D2:4C:B1:B7:57:CE:AA:BB:54

SHA1:C0:AD:FC:86:53:CB:4F:92:D6:6C:2E:23:25:8F:EF:89:7D:8D:3A:EB

签名算法名称:MD5withRSA

版本: 3

认证 [2]:

所有者:CN=mars_inter, OU=rv, O=rcd, L=ZB, ST=bj, C=China

签发人:CN=mars_ca, OU=rv, O=rcd, L=ZB, ST=bj, C=China

序列号:4eb449c7

有效期: Sat Nov 05 04:23:35 CST 2011 至Wed Jan 22 04:23:35 CST 2020

证书指纹:

MD5:23:6C:C0:46:67:CF:9E:4E:EF:A9:74:95:AB:EE:37:21

SHA1:54:86:85:BC:9C:D5:D2:E8:A4:E6:33:DD:4F:42:87:FB:2A:92:F3:84

签名算法名称:MD5withRSA

版本: 3

认证 [3]:

所有者:CN=mars_ca, OU=rv, O=rcd, L=ZB, ST=bj, C=China

签发人:CN=mars_ca, OU=rv, O=rcd, L=ZB, ST=bj, C=China

序列号:4eb449c5

有效期: Sat Nov 05 04:23:33 CST 2011 至Wed Jan 04 04:23:33 CST 2012

证书指纹:

MD5:49:44:8A:79:3C:62:ED:66:AA:20:D6:BF:65:3E:23:C4

SHA1:EA:92:AE:59:D1:8D:B6:2F:33:B7:65:CC:6E:B0:B5:7D:40:CF:45:BE

签名算法名称:SHA1withRSA

版本: 3

双向认证TLS网络包：
filter:
tcp.port==9527&&ssl

route add mask 255.255.255.255 metric 1

route delete

route add 192.168.0.100 mask

255.255.255.255 192.168.0.1

metric 1

route delete 192.168.0.100

1： 54292[client] 9527[server] TLSv1 Client Hello

2，3，4，5： 9527[server] 54292[client] TLSv1 Server Hello, Certificate, Server Key Exchange, Certificate Request, Server Hello Done

6，7： 54292[client] 9527[server] TLSv1 Certificate, Client Key Exchange

8： 54292[client] 9527[server] TLSv1 Certificate Verify

9，10： 54292[client] 9527[server] TLSv1 Change Cipher Spec, Encrypted Handshake Message

11，12： 9527[server] 54292[client] TLSv1 Change Cipher Spec (Finished)

9527[server] 54292[client] TLSv1 Encrypted Handshake Message, Application Data, Application Data, Encrypted Alert

双向认证流程：

Lu Han 2011-11-05 04:27 发表评论

轮询客户端的实现

Lu Han — Fri, 08 Jul 2011 08:01:00 GMT

Scenario
服务器1:客户端n 发送Notification给客户端的后处理
服务器端给第一个客户端发送notification，然后在限定时间内，等待客户端作出回应—向服务器发送request。如果客户端一直没有回复，服务器会在到达限定时间后，向第二个客户端发送notification。如果客户端在限定时间内回复，服务器端放弃再给其他客户端发送消息。

Design
服务器、客户端使用socket发送和接收信息
发送端存在一个客户端列表，每次发送一给一个客户端，发送后，向Helper发送添加该客户端id的请求。
客户端收到信息会向Helper发送删除该id的请求。
Helper收到add时，启动一个ScheduledExecutorService类的schedule，延时启动一个线程，并将该schedule缓存。remove时，从缓存里取出schedule并停止它。如果在延时时间内，线程没有被停止，它会被执行：从缓存中取出，告诉服务器向下一个客户端发送请求。

UML

Code

SendingNotification

ReceivingRequest

Helper

Schedule

Client

Lu Han 2011-07-08 16:01 发表评论

Java远程方法调用实践

Lu Han — Thu, 26 May 2011 15:55:00 GMT

服务器端业务接口继承自Remote

public interface Biz extends Remote {

public String aloha() throws RemoteException;

}

服务器端业务实现该接口

public class BizImpl extends UnicastRemoteObject implements Biz {

private static final long serialVersionUID = -8559392326593037120L;

public BizImpl() throws RemoteException {

super();

}

@Override

public String aloha() throws RemoteException {

return "Aloha Baby.";

}

服务器注册远程实现名称

public class Server {

public Server() {

try {

Biz bis = new BizImpl();

// style-1

Registry registry = LocateRegistry.createRegistry(RMIParameter.PORT);

registry.rebind(RMIParameter.NAME, bis); // replace existing binding name

// style-2

//java.rmi.Naming.rebind(RMIParameter.NAME, bis); // replace existing binding name

} catch (Exception e) {

e.printStackTrace();

}

public static void main(String args[]) {

new Server();

}

style-2 需要指定一个Policy文件或者运行rmiregistry

java -Djava.security.policy=folder_x/rmi/policy_file creative.fire.rmi.Server

Policy文件的内容为：

grant{

permission java.net.SocketPermission "localhost:9527", "connect, resolve";

};

运行rmiregistry是修改 JDK 目录下的jre/lib/security/java.policy

rmiregistry（linux）

start rmiregistry(windows)

允许任何人(targets)作任何事情(actions)：

grant{

permission java.security.AllPermission "","";

};

grant {

permission java.security.AllPermission;

};

客户端打桩调用

public class Client {

public static void main(String args[]) {

try {

Biz bis = (Biz) Naming.lookup(RMIPREFIX + PORT + NAME);

System.out.println(bis.aloha());

} catch (Exception e) {

e.printStackTrace();

}

Lu Han 2011-05-26 23:55 发表评论

Java安全传输实践

Lu Han — Thu, 26 May 2011 06:48:00 GMT

摘要: 传输层安全访问是通过身份验证和加密传输的过程。JDK的JSSE提供了传输层安全访问的实现。本文旨在通过一个完整的TLS通讯实例，辨析一个普遍的误导。网络上停留在理论的简单实例通常存在一个误导。在双向信任的情况下，双方都需要信任对方的证书。这样的例子很多，普遍拷贝并简述过程。其实，在实践中发现，如果双方都信任一个权威的CA，并持有该CA根证书和该CA签发的证书，即可以信任对方，实... 阅读全文

Lu Han 2011-05-26 14:48 发表评论

Java线程池类ThreadPoolExecutor浅析

Lu Han — Sat, 04 Dec 2010 11:09:00 GMT

本文是对java线程池的粗浅分析，视野局限于线程池的基本实现，不包含生命周期，状态管理。

线程池的特点是将任务的提交和执行分开。这样做的好处是，能使处理器尽量多地同时执行任务。

为此，线程池提供了两个角色：
任务 task
执行任务的工人 worker

与此相关，需要考虑：

工人的数量：
工人数量的考量是线程池设计的一个关键。因此，这一点由构造线程池时，提供的头两个参数决定。
最小雇佣数量 corePoolSize
最多工人数量 maximumPoolSize

何时解雇多余最小雇佣数量的工人：
工人多余任务时，它们会等待任务的到来，如果规定时间内，还没有任务，那我们就解雇多余的工人。
这个规定的时间就是构造子里的第三，第四个参数。

能接受的任务数量：
一个工人，某一时间只能处理一个任务。工人的数量是有限的，因此多余工人数量的任务来了时：
线程池就要考虑是否接受
Y:
处于等待中的任务堆积到多少就不再允许接受任务：
规定等待任务列表的容量[bound]，达到容量后不再接受新任务。

无限制地接受等待任务[unbound]
设置何种任务等待列表由构造子的第五个参数决定。
long keepAliveTime, TimeUnit unit

N:
以何种方式拒绝：
由构造子的第七个参数决定。

第六个参数决定了
工人手里执行任务线程的工厂方法。

工作原理：

1.当工人数量没有达到最小雇佣数量时，每当任务来临，线程池都要创建一个工人，然后从线程工厂里创建一个新的线程，把任务作为该线程的target，把线程交给工人，把工人加入工人集合。该任务随即被执行。

2.如果任务来临时，当前工人数量poolSize已经大于最小雇佣数量，表明工人已经雇佣的差不多了，先让任务等待吧。
线程池尝试把任务加入任务列表，如果成功，任务提交的步骤就结束了。

2.5.任务列表是并发阻塞队列，工人会不断地尝试从队列里获取任务，如果获取到任务(请看5)，工人就把任务拿去执行。这是任务的执行步骤。

3.如果加入队列失败，说明任务列表已经满了，不能再往里塞任务了。
这时，线程池判断工人数量是否达到最多工人数量。
如果还没有，则决定再雇佣一个工人(这和开始雇佣工人的步骤没有两样)。

4.如果已经达到雇佣上线，线程池没有办法了，只好拒绝该任务。
拒绝的方式有：
1、抛出异常给任务递送者，告诉他“老子累屁了，老子真的不干了”。 --这太粗暴了。线程池默认就这么干！
2、偷蔫儿地丢弃这个任务。 --这太猥琐了。
3、从任务列表里丢弃一个最近的任务，然后把这个任务放里。--这太势利眼了。
4、还给任务递送者，让他自己干。--这太无耻了。

5.线程池让工人等待任务的策略分两种(本文不考虑生命周期和状态)：
死等！当工人数量少于或者等于最低雇佣数量时，它们没啥任务干了，就必须死等。
如果在给定时间内，没有任务来到，线程池开始数人头，如果不多于最低雇佣数量，这个工人还得重新等一个给定时间那么长。

6.否则，线程池把该工人的线程结束，告诉当前等待的工人，你没有任务了。不要再等了。

7.没有拿到任务的工人，被清除出工人集合--该工人正式下岗。

feuyeux@gmail.com

Lu Han 2010-12-04 19:09 发表评论