国产69精品久久久久9999,久久精品水蜜桃av综合天堂 ,久久精品成人免费看

ExecutorService與Executors例子的簡單剖析

對于多線程有了一點了解之后，那么來看看java.lang.concurrent包下面的一些東西。在此之前，我們運行一個線程都是顯式調用了 Thread的start()方法。我們用concurrent下面的類來實現一下線程的運行，而且這將成為以后常用的方法或者實現思路。

看一個簡單的例子：

Java代碼

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代碼

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代碼

void execute(Runnable command)

        二、Executors
        Executors是一個類，直接援引JDK文檔的說明來說一下這個類的作用：

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代碼

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

在源碼中我們可以知道兩點，1、這個方法返回類型是ExecutorService；2、此方法返回值實際是另一個類的實例。看一下這個類的信息：

Java代碼

public class ThreadPoolExecutor extends AbstractExecutorService {
..........
private final BlockingQueue<Runnable> workQueue;//這個變量在下面會提到
..........
}

ThreadPoolExecutor繼承了AbstractExecutorService,而AbstractExecutorService又實現了ExecutorService接口。所以，根據多態，ThreadPoolExecutor可以看作是ExecutorService類型。

線程執行的最關鍵的一步是執行了executor方法，根據java的動態綁定，實際執行的是ThreadPoolExecutor所實現的executor方法。看看源碼：

Java代碼

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代碼

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代碼

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代碼

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代碼

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 小果子閱讀(672) | 評論 (0) | 編輯收藏

移動環境下push技術開發（01-androidpn環境的配置） ( 轉 )

轉自: 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/這個論壇提問。

posted @ 2012-09-27 10:54 小果子閱讀(1866) | 評論 (0) | 編輯收藏

iconv

今天在提取抓取到的網頁內容的正文時候，發現結果老是不完整，開始以為是提取不正確，然后去一步步分析提取結果，發現沒問題，最后才發現是編碼轉換的環節的問題。我開始是直接使用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 小果子閱讀(225) | 評論 (0) | 編輯收藏

android 4.0 以上平臺選擇圖片報錯Attempted to access a cursor after it has been closed.

選擇圖片后 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 小果子閱讀(1073) | 評論 (1) | 編輯收藏

yii (3)

$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 小果子閱讀(248) | 評論 (0) | 編輯收藏

僅列出標題

常用鏈接

隨筆分類

Blog

Company

Friends&Acmers

QT

搜索

最新評論

閱讀排行榜