对于多线程有了一点了解之后,那么来看看java.lang.concurrent包下面的一些东西。在此之前,我们运行一个线程都是显式调用了 Thread的start()方法。我们用concurrent下面的类来实现一下线程的运行,而且这将成为以后常用的方法或者实现思路。
看一个简单的例子:
Java代码
![](http://paddy-w.iteye.com/images/spinner.gif)
- public class CacheThreadPool {
- public static void main(String[] args) {
- ExecutorService exec=Executors.newCachedThreadPool();
- for(int i=0;i<5;i++)
- exec.execute(new LiftOff());
- exec.shutdown();//并不是终止线程的运行,而是禁止在这个Executor中添加新的任务
- }
- }
这个例子其实很容易看懂,ExecutorService中有一个execute方法,这个方法的参数是Runnable类型。也就是说,将一个实现了Runnable类型的类的实例作为参数传入execute方法并执行,那么线程就相应的执行了。
一、ExecutorService 先看看ExecutorService,这是一个接口,简单的列一下这个接口:
Java代码
![收藏代码](http://paddy-w.iteye.com/images/icon_star.png)
- public interface ExecutorService extends Executor {
-
- void shutdown();
-
- List<Runnable> shutdownNow();
-
- boolean isShutdown();
-
- boolean isTerminated();
-
- boolean awaitTermination(long timeout, TimeUnit unit)
-
- <T> Future<T> submit(Callable<T> task);
-
- <T> Future<T> submit(Runnable task, T result);
-
- Future<?> submit(Runnable task);
-
- <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
-
- <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
-
- <T> T invokeAny(Collection<? extends Callable<T>> tasks)
-
- <T> T invokeAny(Collection<? extends Callable<T>> tasks,
- long timeout, TimeUnit unit)
- }
ExecuteService继承了Executor,Executor也是一个接口,里面只有一个方法:
Java代码
![收藏代码](http://paddy-w.iteye.com/images/icon_star.png)
- void execute(Runnable command)
二、Executors Executors是一个类,直接援引JDK文档的说明来说一下这个类的作用:
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.
在上面的例子中,我们用到了newCachedThreadPool()方法。看一下这个方法:
Java代码
![收藏代码](http://paddy-w.iteye.com/images/icon_star.png)
- public static ExecutorService newCachedThreadPool() {
- return new ThreadPoolExecutor(0, Integer.MAX_VALUE,
- 60L, TimeUnit.SECONDS,
- new SynchronousQueue<Runnable>());
- }
在源码中我们可以知道两点,1、这个方法返回类型是ExecutorService;2、此方法返回值实际是另一个类的实例。看一下这个类的信息:
Java代码
![收藏代码](http://paddy-w.iteye.com/images/icon_star.png)
- public class ThreadPoolExecutor extends AbstractExecutorService {
- ..........
- private final BlockingQueue<Runnable> workQueue;//这个变量在下面会提到
- ..........
- }
ThreadPoolExecutor继承了AbstractExecutorService,而AbstractExecutorService又实现 了ExecutorService接口。所以,根据多态,ThreadPoolExecutor可以看作是ExecutorService类型。
线程执行的最关键的一步是执行了executor方法,根据java的动态绑定,实际执行的是ThreadPoolExecutor所实现的executor方法。看看源码:
Java代码
![收藏代码](http://paddy-w.iteye.com/images/icon_star.png)
- public class ThreadPoolExecutor extends AbstractExecutorService {
- ..........
- public void execute(Runnable command) {
- if (command == null)
- throw new NullPointerException();
- if (poolSize >= corePoolSize || !addIfUnderCorePoolSize(command)) {
- if (runState == RUNNING && workQueue.offer(command)) {
- if (runState != RUNNING || poolSize == 0)
- ensureQueuedTaskHandled(command);
- }
- else if (!addIfUnderMaximumPoolSize(command))
- reject(command); // is shutdown or saturated
- }
- }
- ..........
- }
根据程序正常执行的路线来看,这个方法中比较重要的两个地方分别是:
1、workQueue.offer(command)
workQueue在上面提到过,是BlockingQueue<Runnable>类型的变量,这条语句就是将Runnable类型的实例加入到队列中。
2、ensureQueuedTaskHandled(command)
这个是线程执行的关键语句。看看它的源码:
Java代码
![收藏代码](http://paddy-w.iteye.com/images/icon_star.png)
- public class ThreadPoolExecutor extends AbstractExecutorService {
- ..........
- private void ensureQueuedTaskHandled(Runnable command) {
- final ReentrantLock mainLock = this.mainLock;
- mainLock.lock();
- boolean reject = false;
- Thread t = null;
- try {
- int state = runState;
- if (state != RUNNING && workQueue.remove(command))
- reject = true;
- else if (state < STOP &&
- poolSize < Math.max(corePoolSize, 1) &&
- !workQueue.isEmpty())
- t = addThread(null);
- } finally {
- mainLock.unlock();
- }
- if (reject)
- reject(command);
- else if (t != null)
- t.start();
- }
- ..........
- }
在这里我们就可以看到最终执行了t.start()方法来运行线程。在这之前的重点是t=addThread(null)方法,看看addThread方法的源码:
Java代码
![收藏代码](http://paddy-w.iteye.com/images/icon_star.png)
- public class ThreadPoolExecutor extends AbstractExecutorService {
- ..........
- private Thread addThread(Runnable firstTask) {
- Worker w = new Worker(firstTask);
- Thread t = threadFactory.newThread(w);
- if (t != null) {
- w.thread = t;
- workers.add(w);
- int nt = ++poolSize;
- if (nt > largestPoolSize)
- largestPoolSize = nt;
- }
- return t;
- }
- ..........
- }
这里两个重点,很明显:
1、Worker w = new Worker(firstTask)
2、Thread t = threadFactory.newThread(w)
先看Worker是个什么结构:
Java代码
![收藏代码](http://paddy-w.iteye.com/images/icon_star.png)
- public class ThreadPoolExecutor extends AbstractExecutorService {
- ..........
- private final class Worker implements Runnable {
- ..........
- Worker(Runnable firstTask) {
- this.firstTask = firstTask;
- }
-
- private Runnable firstTask;
- ..........
-
- public void run() {
- try {
- Runnable task = firstTask;
- firstTask = null;
- while (task != null || (task = getTask()) != null) {
- runTask(task);
- task = null;
- }
- } finally {
- workerDone(this);
- }
- }
- }
-
- Runnable getTask() {
- for (;;) {
- try {
- int state = runState;
- if (state > SHUTDOWN)
- return null;
- Runnable r;
- if (state == SHUTDOWN) // Help drain queue
- r = workQueue.poll();
- else if (poolSize > corePoolSize || allowCoreThreadTimeOut)
- r = workQueue.poll(keepAliveTime, TimeUnit.NANOSECONDS);
- else
- r = workQueue.take();
- if (r != null)
- return r;
- if (workerCanExit()) {
- if (runState >= SHUTDOWN) // Wake up others
- interruptIdleWorkers();
- return null;
- }
- // Else retry
- } catch (InterruptedException ie) {
- // On interruption, re-check runState
- }
- }
- }
- }
- ..........
- }
Worker是一个内部类。根据之前可以知道,传入addThread的参数是null,也就是说Work中firstTask为null。
在看看newThread是一个什么方法:
Java代码
![收藏代码](http://paddy-w.iteye.com/images/icon_star.png)
- public class Executors {
- ..........
- static class DefaultThreadFactory implements ThreadFactory {
- ..........
- public Thread newThread(Runnable r) {
- Thread t = new Thread(group, r,
- namePrefix + threadNumber.getAndIncrement(),
- 0);
- if (t.isDaemon())
- t.setDaemon(false);
- if (t.getPriority() != Thread.NORM_PRIORITY)
- t.setPriority(Thread.NORM_PRIORITY);
- return t;
- }
- ..........
- }
- ..........
- }
通过源码可以得知threadFactory的实际类型是DefaultThreadFactory,而DefaultThreadFactory是Executors的一个嵌套内部类。
之前我们提到了t.start()这个方法执行了线程。那么现在从头顺一下,看看到底是执行了谁的run方法。首先知 道,t=addThread(null),而addThread内部执行了下面三步,Worker w = new Worker(null);Thread t = threadFactory.newThread(w);return t;这里两个t是一致的。
从这里可以看出,t.start()实际上执行的是Worker内部的run方法。run()内部会在if条件里面使用“短路”:判断firstTask 是否为null,若不是null则直接执行firstTask的run方法;如果是null,则调用getTask()方法来获取Runnable类型实 例。从哪里获取呢?workQueue!在execute方法中,执行ensureQueuedTaskHandled(command)之前就已经把 Runnable类型实例放入到workQueue中了,所以这里可以从workQueue中获取到。
转自:
http://paddy-w.iteye.com/blog/1039530
posted @
2012-10-30 21:56 小果子 阅读(650) |
评论 (0) |
编辑 收藏
转自: 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。
![](http://www.189works.com/data/attachment/portal/et2/201205/ET29821020728131.png)
2.2、服务器端的配置
首先在MyEclispe里面配置Tomcat,到apache官网下个纯的tomcat,不要是什么和apache整合的,就单单是tomcat。然后在本地磁盘解压。把tomcat集成到MyEclipse。按照下图操作。
![](http://www.189works.com/data/attachment/portal/et2/201205/ET29821020728132.png)
然后在Server视图里面启动Tomcat。
![](http://www.189works.com/data/attachment/portal/et2/201205/ET29821020728133.png)
看启动日志。
![](http://www.189works.com/data/attachment/portal/et2/201205/ET29821020728134.png)
启动成功后,打来浏览器,输入:http://localhost:8080/, 如果出现Tomcat的主页,就说明的tomcat配置成功了。然后关闭Tomcat。
把解压后的服务器端代码(Androidpn)导入MyEclipse。导入后的项目结构如下图所示。在数据库里面新建一个名为“android”的数据库,再修改jdbc.properties这个文件,关键是红框标记的几处,改成你的MySql对应的值。
![](http://www.189works.com/data/attachment/portal/et2/201205/ET29821020728135.png)
如果你不是用的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的首页。
![](http://www.189works.com/data/attachment/portal/et2/201205/ET29821020728136.png)
三、测试
在模拟器或真机上运行客户端程序,会出现下图的界面。
![](http://www.189works.com/data/attachment/portal/et2/201205/ET29821020728137.png)
同时MyEclipse的控制台会打印很多log。
![](http://www.189works.com/data/attachment/portal/et2/201205/ET29821020728138.png)
过一会服务器的Web页面的Users列表和Sessions列表里面都会出现你的记录。
![](http://www.189works.com/data/attachment/portal/et2/201205/ET29821020728139.png)
![](http://www.189works.com/data/attachment/portal/et2/201205/ET298210207281310.png)
然后你就可以推送了。
![](http://www.189works.com/data/attachment/portal/et2/201205/ET298210207281311.png)
客户端收到信息后的显示界面如下。
![](http://www.189works.com/data/attachment/portal/et2/201205/ET298210207281312.png)
四、Linux下androidpn环境的配置
其实和上述的步骤一样,只是你把上述的Tomcat根目录下的webapps目录下的“Androidpn.war”拷贝到Linux下面的Tomcat的对应目录即可,至于Linux下怎么配置java以及tomcat的环境,请自己网上搜索。
项目放好之后,到tomcat的bin目录下,运行:./startup.sh 来启动tomcat,启动之后,运行:netstat -antupl 看下图的端口是否处于监听状态。
![](http://www.189works.com/data/attachment/portal/et2/201205/ET298210207281313.png)
如果是的话,现在你就可以启动客户端了。
要看tomcat的log的话,进入tomcat的logs目录运行:tail -f ./catalina.out
好了,如果你按照上述的步骤还是不行的话,加入QQ群(210555217)提问,或者在http://phonepush.sinaapp.com/这个论坛提问。
posted @
2012-09-27 10:54 小果子 阅读(1838) |
评论 (0) |
编辑 收藏
今天在提取抓取到的网页内容的正文时候,发现结果老是不完整,开始以为是提取不正确,然后去一步步分析提取结果,发现没问题,最后才发现是编码转换的环节的问题。我开始是直接使用iconv函数,
$txtContent = iconv("utf-8",'GBK',$txtContent);
utf-8直接转gbk,这样问题就来了,当有些字符无法转换的时候就从此处断开,导致内容不完整。后来又重新查手册,才发现iconv还有两个可选的辅助参数:TRANSLIT和IGNORE ,(其中IGNORE 就是说遇到无法转换的就跳过)。 其实也怪自己太粗心,刚开始一看iconv函数参数就三个,而且例子中也没有特别的,就懒得去看英文解释了,直接使用,直到出现了问题。
Description
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.
posted @
2012-09-03 15:46 小果子 阅读(214) |
评论 (0) |
编辑 收藏
选择图片后 onActivityResult中的代码如下:
Uri uri = data.getData();
if (uri != null)
{
mFilePath = new URIUtils().getPathFromUri(uri);
}
解决办法如注释中的所示。 4.0以上平台会自动关闭cursor
protected String getPath(Uri uri)
{
String filePath = "";
String[] projection = {MediaColumns.DATA };
Cursor cursor = managedQuery(uri,
projection,
null,
null,
null);
if (cursor != null)
{
int columnIndex = cursor.getColumnIndexOrThrow(MediaColumns.DATA);
cursor.moveToFirst();
filePath = cursor.getString(columnIndex);
try
{
//4.0以上的版本会自动关闭 (4.0--14;; 4.0.3--15)
if(Integer.parseInt(Build.VERSION.SDK) < 14)
{
cursor.close();
}
}catch(Exception e)
{
Log.error(TAG, "error:" + e);
}
}
return filePath;
}
posted @
2012-08-31 15:16 小果子 阅读(1053) |
评论 (1) |
编辑 收藏
$criteria = new CDbCriteria;
$criteria->addCondition("id=1"); //查询条件,即where id = 1
$criteria->addInCondition('id', array(1,2,3,4,5)); //代表where id IN (1,23,,4,5,);
$criteria->addNotInCondition('id', array(1,2,3,4,5));//与上面正好相法,是NOT IN
$criteria->addCondition('id=1','OR');//这是OR条件,多个条件的时候,该条件是OR而非AND
$criteria->addSearchCondition('name', '分类');//搜索条件,其实代表了。。where name like '%分类%'
$criteria->addBetweenCondition('id', 1, 4);//between 1 and 4
$criteria->compare('id', 1); //这个方法比较特殊,他会根据你的参数自动处理成addCondition或者addInCondition,
//即如果第二个参数是数组就会调用addInCondition
$criteria->addCondition("id = :id");
$criteria->params[':id']=1;
$criteria->select = 'id,parentid,name'; //代表了要查询的字段,默认select='*';
$criteria->join = 'xxx'; //连接表
$criteria->with = 'xxx'; //调用relations
$criteria->limit = 10; //取1条数据,如果小于0,则不作处理
$criteria->offset = 1; //两条合并起来,则表示 limit 10 offset 1,或者代表了。limit 1,10
$criteria->order = 'xxx DESC,XXX ASC' ;//排序条件
$criteria->group = 'group 条件';
$criteria->having = 'having 条件 ';
$criteria->distinct = FALSE; //是否唯一查询
posted @
2012-08-30 12:16 小果子 阅读(234) |
评论 (0) |
编辑 收藏