Java代码  

1. public class CacheThreadPool {  
2.     public static void main(String[] args) {  
3.         ExecutorService exec=Executors.newCachedThreadPool();  
4.         for(int i=0;i<5;i++)  
5.             exec.execute(new LiftOff());  
6.         exec.shutdown();//并不是终止线程的运行，而是禁止在这个Executor中添加新的任务  
7.     }  
8. }  

Java代码  

1. public interface ExecutorService extends Executor {  
2.   
3.     void shutdown();  
4.   
5.     List<Runnable> shutdownNow();  
6.   
7.     boolean isShutdown();  
8.   
9.     boolean isTerminated();  
10.   
11.     boolean awaitTermination(long timeout, TimeUnit unit)  
12.   
13.     <T> Future<T> submit(Callable<T> task);  
14.   
15.     <T> Future<T> submit(Runnable task, T result);  
16.   
17.     Future<?> submit(Runnable task);  
18.   
19.     <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)  
20.   
21.     <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)  
22.   
23.     <T> T invokeAny(Collection<? extends Callable<T>> tasks)  
24.   
25.     <T> T invokeAny(Collection<? extends Callable<T>> tasks,  
26.                     long timeout, TimeUnit unit)  
27. }  

Java代码  

1. void execute(Runnable command)  

        Factory and utility methods for Executor, ExecutorService, ScheduledExecutorService, ThreadFactory, and Callable classes defined in this package. This class supports the following kinds of methods:
       
• Methods that create and return an ExecutorService set up with commonly useful configuration settings.
       
• Methods that create and return a ScheduledExecutorService set up with commonly useful configuration settings.
       
• Methods that create and return a "wrapped" ExecutorService, that disables reconfiguration by making implementation-specific methods inaccessible.
       
• Methods that create and return a ThreadFactory that sets newly created threads to a known state.
       
• Methods that create and return a Callable out of other closure-like forms, so they can be used in execution methods requiring Callable.
       

Java代码  

1. public static ExecutorService newCachedThreadPool() {  
2.         return new ThreadPoolExecutor(0, Integer.MAX_VALUE,  
3.                                       60L, TimeUnit.SECONDS,  
4.                                       new SynchronousQueue<Runnable>());  
5.     }  

Java代码  

1. public class ThreadPoolExecutor extends AbstractExecutorService {  
2.     ..........  
3.     private final BlockingQueue<Runnable> workQueue;//这个变量在下面会提到  
4.     ..........  
5. }  

Java代码  

1. public class ThreadPoolExecutor extends AbstractExecutorService {  
2.     ..........  
3.     public void execute(Runnable command) {  
4.         if (command == null)  
5.             throw new NullPointerException();  
6.         if (poolSize >= corePoolSize || !addIfUnderCorePoolSize(command)) {  
7.             if (runState == RUNNING && workQueue.offer(command)) {  
8.                 if (runState != RUNNING || poolSize == 0)  
9.                     ensureQueuedTaskHandled(command);  
10.             }  
11.             else if (!addIfUnderMaximumPoolSize(command))  
12.                 reject(command); // is shutdown or saturated  
13.         }  
14.     }  
15.     ..........  
16. }  

Java代码  

1. public class ThreadPoolExecutor extends AbstractExecutorService {  
2.     ..........  
3.     private void ensureQueuedTaskHandled(Runnable command) {  
4.         final ReentrantLock mainLock = this.mainLock;  
5.         mainLock.lock();  
6.         boolean reject = false;  
7.         Thread t = null;  
8.         try {  
9.             int state = runState;  
10.             if (state != RUNNING && workQueue.remove(command))  
11.                 reject = true;  
12.             else if (state < STOP &&  
13.                      poolSize < Math.max(corePoolSize, 1) &&  
14.                      !workQueue.isEmpty())  
15.                 t = addThread(null);  
16.         } finally {  
17.             mainLock.unlock();  
18.         }  
19.         if (reject)  
20.             reject(command);  
21.         else if (t != null)  
22.             t.start();  
23.     }  
24.     ..........  
25. }  

Java代码  

1. public class ThreadPoolExecutor extends AbstractExecutorService {  
2.     ..........  
3.     private Thread addThread(Runnable firstTask) {  
4.         Worker w = new Worker(firstTask);  
5.         Thread t = threadFactory.newThread(w);  
6.         if (t != null) {  
7.             w.thread = t;  
8.             workers.add(w);  
9.             int nt = ++poolSize;  
10.             if (nt > largestPoolSize)  
11.                 largestPoolSize = nt;  
12.         }  
13.         return t;  
14.     }  
15.     ..........  
16. }  

Java代码  

1. public class ThreadPoolExecutor extends AbstractExecutorService {  
2.     ..........  
3.     private final class Worker implements Runnable {  
4.         ..........  
5.         Worker(Runnable firstTask) {  
6.             this.firstTask = firstTask;  
7.         }  
8.   
9.         private Runnable firstTask;  
10.         ..........  
11.   
12.         public void run() {  
13.             try {  
14.                 Runnable task = firstTask;  
15.                 firstTask = null;  
16.                 while (task != null || (task = getTask()) != null) {  
17.                     runTask(task);  
18.                     task = null;  
19.                 }  
20.             } finally {  
21.                 workerDone(this);  
22.             }  
23.         }  
24.     }  
25.   
26.     Runnable getTask() {  
27.         for (;;) {  
28.             try {  
29.                 int state = runState;  
30.                 if (state > SHUTDOWN)  
31.                     return null;  
32.                 Runnable r;  
33.                 if (state == SHUTDOWN)  // Help drain queue  
34.                     r = workQueue.poll();  
35.                 else if (poolSize > corePoolSize || allowCoreThreadTimeOut)  
36.                     r = workQueue.poll(keepAliveTime, TimeUnit.NANOSECONDS);  
37.                 else  
38.                     r = workQueue.take();  
39.                 if (r != null)  
40.                     return r;  
41.                 if (workerCanExit()) {  
42.                     if (runState >= SHUTDOWN) // Wake up others  
43.                         interruptIdleWorkers();  
44.                     return null;  
45.                 }  
46.                 // Else retry  
47.             } catch (InterruptedException ie) {  
48.                 // On interruption, re-check runState  
49.             }  
50.         }  
51.     }  
52.     }  
53.     ..........  
54. }  

Java代码  

1. public class Executors {  
2.     ..........  
3.     static class DefaultThreadFactory implements ThreadFactory {  
4.         ..........  
5.         public Thread newThread(Runnable r) {  
6.             Thread t = new Thread(group, r,  
7.                                   namePrefix + threadNumber.getAndIncrement(),  
8.                                   0);  
9.             if (t.isDaemon())  
10.                 t.setDaemon(false);  
11.             if (t.getPriority() != Thread.NORM_PRIORITY)  
12.                 t.setPriority(Thread.NORM_PRIORITY);  
13.             return t;  
14.         }  
15.         ..........  
16.     }  
17.     ..........  
18. }  

转自: http://www.189works.com/article-58560-1.html

一、缘由

其实说白了就是研究androidpn这个开源项目，只因我的本科毕业设计的题目就是“移动环境下push技术开发”，所以起这个作为本篇博文的题目。其实我本来是想等我的毕业设计答辩结束后，再总结，再分享的，可是最近群里很多人整个环境都不会配，所以我就先写一篇环境的配置吧。

当然我起初也是在各位前辈的基础上学习的，关于androidpn网上的资料还是很多的，大家自己看。这里只贴出两个我认为比较好的链接：
Android推送通知指南：http://blog.csdn.net/joshua_yu/article/details/6563587
用androidpn来实现推送（Jclick）：http://www.iteye.com/topic/1117043?page=13

刚开始的时候，我就是用的Jclick修改后的tomcat版本，在这个基础上一点一点的修改的，我的更新日志，后来交流的人多了，我就建了一个QQ群（210555217），群共享里面有各种版本（有用JSON的、有用SSH的、以及增加离线消息和回执功能的等等）。我今天就拿小强共享的版本来说明。可以在群共享下载，也可以在本文后面的链接下载。


二、Windows下androidpn环境的配置

在配置之前，请关闭或者删除你工作空间里面跟androidpn相关的其他工程。严格按照下面步骤来搞，否则你出现问题，我也不知道怎么处理的。

2.1、客户端配置

把 解压后的的“androidpn-client”导入Eclipse，导入后整个工程的目录如下，然后打开 “androidpn.properties”，修改“xmppHost”，如果你是用模拟器测试的话，改成“10.0.2.2”，如果是真机测试的话改 成你的电脑的IP。

2.2、服务器端的配置

首先在MyEclispe里面配置Tomcat，到apache官网下个纯的tomcat，不要是什么和apache整合的，就单单是tomcat。然后在本地磁盘解压。把tomcat集成到MyEclipse。按照下图操作。

然后在Server视图里面启动Tomcat。

看启动日志。

启动成功后，打来浏览器，输入：http://localhost:8080/， 如果出现Tomcat的主页，就说明的tomcat配置成功了。然后关闭Tomcat。

把解压后的服务器端代码（Androidpn）导入MyEclipse。导入后的项目结构如下图所示。在数据库里面新建一个名为“android”的数据库，再修改jdbc.properties这个文件，关键是红框标记的几处，改成你的MySql对应的值。

如果你不是用的MySql，就用相应的数据库jar包替换mysql的jar包，然后再修改jdbc.properties。其他数据库对应的写法如下。
------SQL Server 2005------
# JDBC Configuration
jdbcDriverClassName=com.microsoft.jdbc.sqlserver.SQLServerDriver
jdbcUrl=jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=android
hibernate.dialect=org.hibernate.dialect.SQLServerDialect
jdbcUsername=sa
jdbcPassword=sql

------SQL Server 2008------
jdbcDriverClassName=com.microsoft.sqlserver.jdbc.SQLServerDriver
jdbcUrl=jdbc:sqlserver://localhost:1433;DatabaseName=android;integratedSecurity=false
hibernate.dialect=org.hibernate.dialect.SQLServerDialect
jdbcUsername=sa
jdbcPassword=sql

修改好了之后，部署到Tomcat上，部署的过程中注意下图的选择。之后启动Tomcat，然后在浏览器里面输入：http://localhost:8080/Androidpn，正常情况下是可以出现Androidpn的首页。

三、测试

在模拟器或真机上运行客户端程序，会出现下图的界面。

同时MyEclipse的控制台会打印很多log。

过一会服务器的Web页面的Users列表和Sessions列表里面都会出现你的记录。

然后你就可以推送了。

客户端收到信息后的显示界面如下。

四、Linux下androidpn环境的配置

其实和上述的步骤一样，只是你把上述的Tomcat根目录下的webapps目录下的“Androidpn.war”拷贝到Linux下面的Tomcat的对应目录即可，至于Linux下怎么配置java以及tomcat的环境，请自己网上搜索。

项目放好之后，到tomcat的bin目录下，运行：./startup.sh 来启动tomcat，启动之后，运行：netstat -antupl 看下图的端口是否处于监听状态。

如果是的话，现在你就可以启动客户端了。

要看tomcat的log的话，进入tomcat的logs目录运行：tail -f ./catalina.out

好了，如果你按照上述的步骤还是不行的话，加入QQ群（210555217）提问，或者在http://phonepush.sinaapp.com/这个论坛提问。

$txtContent = iconv("utf-8",'GBK',$txtContent);

utf-8直接转gbk，这样问题就来了，当有些字符无法转换的时候就从此处断开，导致内容不完整。后来又重新查手册，才发现iconv还有两个可选的辅助参数：TRANSLIT和IGNORE ，(其中IGNORE 就是说遇到无法转换的就跳过)。 其实也怪自己太粗心，刚开始一看iconv函数参数就三个，而且例子中也没有特别的，就懒得去看英文解释了，直接使用，直到出现了问题。

string iconv ( string in_charset, string out_charset, string str )

Performs a character set conversion on the string str from in_charset to out_charset. Returns the converted string or FALSE on failure.

If you append the string //TRANSLIT to out_charset transliteration is activated. This means that when a character can't be represented in the target charset, it can be approximated through one or several similarly looking characters. If you append the string //IGNORE, characters that cannot be represented in the target charset are silently discarded. Otherwise, str is cut from the first illegal character.

选择图片后 onActivityResult中的代码如下：