Android OS에서 Looper와 Handler는 Thread간의 메시지 교환 메카니즘에 관여하는 객체이다.

특정 Thread에서 looper 객체를 생성하고, loop를 돌리는 전형적인 구조는 아래와 같다.
  
class LooperThread extends Thread {
      public Handler mHandler;
      
      public void run() {
          Looper.prepare();
          
          mHandler = new Handler() {
              public void handleMessage(Message msg) {
                  // process incoming messages here
              }
          };
          
          Looper.loop();
      }
  }
  

Looper Class

 Looper 클래스는 Thread에 한개씩만 존재할 수 있으며, 이름에서 알수 있듯이 Event Loop 및 Message Queue를 가지는 Class 이다. Looper 클래스는 이 클래스를 생성한 Thread에 묶이게 되며, 이 관계가 성립되면 이후 바꾸거나 끊을 수 없다. 그리고, 생성된 Looper Class는 해당 Thead의 TLS(Thread Local Storage) 영역에 객체가 저장된다.  
 
 Looper의 생성은 prepare()라는 static 메소드에 의해 이루어진다. 
 아래는 Framework의 소스이다. 이미 Thread에 Looper가 만들어진 경우 Runtime Exception을 발생시킨다.
  
[frameworks/base/core/java/android/os/looper.java]
 
     public static final void prepare() {
        if (sThreadLocal.get() != null) {
            throw new RuntimeException("Only one Looper may be created per thread");
        }
        sThreadLocal.set(new Looper());
    }

  Looper Class의 생성자를 보면 다음과 같다.     
     
private Looper() {
        mQueue = new MessageQueue();
        mRun = true;
        mThread = Thread.currentThread();
}
 
 MessageQueue를 생성해 mQueue에 저장해 두며, 현재 Thread 객체를 mThread에 저장해 둔다.
 
 이제 Message Queue를 검색하고 Event를 처리하는 looper() static 메소드를 살펴보자.
 전형적인 while 형태로, queue.next()를 통해 queue안에 처리할 Message가 있는지 검사한다. Message가 있을 경우 Messsage의 Target 객체로 Message를 dispatch시킨다. 이때 Target 객체의 Type은 Handler Class이며 뒤에서 살펴보자.
 
 [frameworks/base/core/java/android/os/looper.java]
   
 public static final void loop() {
        Looper me = myLooper();
        MessageQueue queue = me.mQueue;
        while (true) {
            Message msg = queue.next(); // might block
            //if (!me.mRun) {
            //    break;
            //}
            if (msg != null) {
                if (msg.target == null) {
                    // No target is a magic identifier for the quit message.
                    return;
                }
                if (me.mLogging!= null) me.mLogging.println(
                        ">>>>> Dispatching to " + msg.target + " "
                        + msg.callback + ": " + msg.what
                        );
                msg.target.dispatchMessage(msg);
                if (me.mLogging!= null) me.mLogging.println(
                        "<<<<< Finished to    " + msg.target + " "
                        + msg.callback);
                msg.recycle();
            }
        }
  }
 

Handler Class

 Handler Class는 Looper와는 다르게 생성한 Thread에 여러개가 붙을 수 있으며, Message Queue에 Message를 Post하고, 또 Looper가 Dispatch해 준 Message를 처리하는 일을 하게 된다. 일반적으로 Handler는
    Handler mHandler = new Handler();

로 생성하게 되는데, 그 생성자 내부를 살펴보면 다음과 같다.

[frameworks/base/core/java/android/os/handler.java]
    public Handler() {
        [....]
        
        mLooper = Looper.myLooper();
        if (mLooper == null) {
            throw new RuntimeException(
                "Can't create handler inside thread that has not called Looper.prepare()");
        }
        mQueue = mLooper.mQueue;
        mCallback = null;
    } 

 
Looper 클래스의 myLooper() static 메소드를 호출하는데, 이 메소드는 현재 Thread의 TLS 영역에 저장되어 있던 Looper 객체를 return 해주는 메소드이다. 
그리고, 만약 현재 Thread에 Looper가 생성되어 있지 않다면, Runtime Exception을 던진다. 따라서, User Thread라면 Looper를 prepare 시킨후 Handler를 생성해 주어야 한다. 그리고, Looper의 Queue를 자신의 mQueue 멤버에 저장해 둔다. 이는 Handler.post(msg) 등의 메소드에서 Message를 Looper의 Queue에 쌓아둘때 참조하기 위해서 이다. mCallback의 Callback 클래스를 지정해 두는 것으로 기본값은 null로 설정된다. mCallback 등은 메시지를 dispatch 받았을때 사용되는데, Handler.dispachMessage 메소드를 살펴보면 다음과 같다.

[frameworks/base/core/java/android/os/handler.java]

    /**
     * Handle system messages here.
     */
    public void dispatchMessage(Message msg) {
        if (msg.callback != null) {
            handleCallback(msg);
        } else {
            if (mCallback != null) {
                if (mCallback.handleMessage(msg)) {
                    return;
                }
            }
            handleMessage(msg);
        }
    }


이 메소드는 앞선 Loooper 클래스의 loop() 메소드에서 호출됨 상기하자.
메시지를 받으면 처리되는 우선 순위가 있는데, Message의 callback 이 지정되어 있으면, 그것을 실행시킨다.

handleCallback 메소드는 아래와 같다. 
    private final void handleCallback(Message message) {
        message.callback.run();
    }

사실 Message의 callback 멤버 Type은 Runnable 클래스이고, 그것의 run() 메소드를 실행하는 것이다. 
참고로, Message Queue에는 Handler.Post(Runnable)계열의 메소드를 통해 Runnable을 넣거나(Post 함수 내부에서 Message 객체로 포장된다) Handler.sendMessage(Message) 메소드를 통해 Message 객체를 넣을 수 있다.

msg.callback이 null인 경우,
            
            if (mCallback != null) {
                if (mCallback.handleMessage(msg)) {
                    return;
                }
            }
            handleMessage(msg);
            
Handler의 Callback 객체가 지정되어 있다면, Callback 객체로 메시지를 넘기고, 어느 경우에도 해당하지 않는다면, Handler Class의 handleMeessage() 메소드로 메시지를 넘겨 처리한다. 기본 Handler 클래스의 handleMessage()는 비어있는데, Handler를 사용하는 곳에서 직접 구현을 해 주면 된다. 

참고로, HandlerThread 클래스라는 것이 있는데, 사용상의 편의를 위해 내부적으로 Looper를 생성해 가지고 있는 Thread이다.

Thread, Looper, Handler의 일반적인 동작 관계를 나타내면 아래의 그림과 같다.
※ 관련 링크:

이전에 SQL Server 2005에서의 대량의 데이터를 로딩한 방법 별 수행 성능을 비교한 글을 올린 적이 있습니다. OPENROWSET, BCP, BULK INSERT, SSIS를 이용하여 데이터를 로딩하는 속도 비교를 측정한 글입니다 (http://www.sqlleader.com/mboard.asp?exec=view&strBoardID=SS2005TSQL&intSeq=351)

 

 

이번 글은 BULK INSERT 명령을 이용할 때 여러 경우에 대한 성능 비교 결과를 정리한 것입니다.

 

다음과 같은 형태의 10,000,000 건의 텍스트 파일을 Bulk Insert 명령을 이용하여 테이블로 로딩할 때 옵션에 따른 수행 시간 비교입니다각 경우에 대해 3회 반복 수행을 한 후평균 소요 시간을 이용하여 비교하였습니다.

 

 

[테스트 파일 - TestFile.txt]

Int형 순번 열, 100자리 문자 열 : 10,000,000 

 

 

[저장 테이블 - TESTTABLE]

USE TEMPDB

GO

 

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

--TEST TABLE

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

CREATE TABLE TESTTABLE

(

        SEQ INT,

        COL CHAR(100)

)

GO

   ※ DB File Size 증가로 인한 지연을 막기 위해 DB Size를 충분히 크게 늘린 후 수행함.

 

 

 

TEST 1) 인덱스가 없는 테이블에 로딩

--인덱스가 없는 테이블에 로딩

BULK INSERT TESTTABLE FROM 'D:\TestFile.txt'

WITH

      (

         FIELDTERMINATOR =',',

         ROWTERMINATOR ='\n'

      )

GO

처리 시간

              1회 00:01:48

              2회 00:01:50

              3회 00:01:49

             평균 00:01:49 (109)

 

 

 

TEST 2) 인덱스가 없는 테이블에 로딩 + TABLOCK 옵션 적용

--인덱스가 없는 테이블에 로딩 + TABLOCK 옵션

BULK INSERT TESTTABLE FROM 'D:\TestFile.txt'

WITH

      (

         FIELDTERMINATOR =',',

         ROWTERMINATOR ='\n',

         TABLOCK

      )

GO

처리 시간

              1회 00:00:34

              2회 00:00:33

              3회 00:00:34

             평균 00:00:34 (34)

 

 

 

TEST 3) 인덱스가 없는 테이블에 로딩 + TABLOCK 옵션 적용 + 일괄 처리 크기 100,000으로 설정

--인덱스가 없는 테이블에 로딩 + TABLOCK 옵션 + RPB 100,000

BULK INSERT TESTTABLE FROM 'D:\TestFile.txt'

WITH

      (

         FIELDTERMINATOR =',',

         ROWTERMINATOR ='\n',

         TABLOCK,

         ROWS_PER_BATCH = 100000

      )

GO

처리 시간

              1회 00:00:33

              2회 00:00:33

              3회 00:00:34

             평균 00:00:33 (33)

 

 

 

 

[Clustered Index 생성]

--Seq 컬럼에 Clustered Index 생성

CREATE CLUSTERED INDEX CIX_TESTTABLE ON TESTTABLE(SEQ)

GO

 

 

 

TEST 4) Clustered Index가 있는 테이블에 로딩

--Clustered Index 있는 테이블에 로딩

BULK INSERT TESTTABLE FROM 'D:\TestFile.txt'

WITH

      (

         FIELDTERMINATOR =',',

         ROWTERMINATOR ='\n'

      )

GO

처리 시간

              1회 00:03:40

              2회 00:03:39

              3회 00:03:39

             평균 00:03:39 (219)

 

 

 

TEST 5) Clustered Index가 있는 테이블에 로딩 + 일괄 처리 크기 100,000

-- Clustered Index 있는 테이블에 로딩

-- RPB 100,000

BULK INSERT TESTTABLE FROM 'D:\TestFile.txt'

WITH

      (

         FIELDTERMINATOR =',',

         ROWTERMINATOR ='\n',

         ROWS_PER_BATCH = 100000

      )

GO

처리 시간

              1회 00:02:49

              2회 00:02:47

              3회 00:02:48

             평균 00:02:48 (168)

 

 

 

TEST 6) Clustered Index가 있는 테이블에 로딩 + ORDER 옵션

-- Clustered Index 있는 테이블에 로딩

-- ORDER 옵션

BULK INSERT TESTTABLE FROM 'D:\TestFile.txt'

WITH

      (

         FIELDTERMINATOR =',',

         ROWTERMINATOR ='\n',

         ORDER(SEQ ASC)

      )

GO

처리 시간

              1회 00:02:21

              2회 00:02:21

              3회 00:02:20

             평균 00:02:21 (141)

 

 

 

TEST 7) Clustered Index가 있는 테이블에 로딩 + 일괄 처리 크기 100,000 + ORDER 옵션

-- Clustered Index 있는 테이블에 로딩

-- RPB 100,000 + ORDER 옵션

BULK INSERT TESTTABLE FROM 'D:\TestFile.txt'

WITH

      (

         FIELDTERMINATOR =',',

         ROWTERMINATOR ='\n',

         ROWS_PER_BATCH = 100000,

         ORDER(SEQ ASC)

      )

GO

처리 시간

              1회 00:02:20

              2회 00:02:21

              3회 00:02:21

             평균 00:02:21 (141)

 

 

 

TEST 8) Clustered Index가 있는 테이블에 로딩 + ORDER 옵션 + TABLOCK 옵션

-- Clustered Index 있는 테이블에 로딩

-- ORDER 옵션 + TABLOCK 옵션

BULK INSERT TESTTABLE FROM 'D:\TestFile.txt'

WITH

      (

         FIELDTERMINATOR =',',

         ROWTERMINATOR ='\n',

         ORDER(SEQ ASC),

         TABLOCK

      )

GO

처리 시간

              1회 00:00:37

              2회 00:00:37

              3회 00:00:37

             평균 00:00:37 (37)

 

 

 

TEST 9) Clustered Index가 있는 테이블에 로딩 + ORDER 옵션 + TABLOCK 옵션 + 일괄 처리 크기 100,000

-- Clustered Index 있는 테이블에 로딩

-- RPB 100,000 + ORDER 옵션 + TABLOCK 옵션

BULK INSERT TESTTABLE FROM 'D:\TestFile.txt'

WITH

      (

         FIELDTERMINATOR =',',

         ROWTERMINATOR ='\n',

         ROWS_PER_BATCH = 100000,

         ORDER(SEQ ASC),

         TABLOCK

      )

GO

처리 시간

              1회 00:00:36

              2회 00:00:37

              3회 00:00:37

             평균 00:00:37 (37)

 

 

 

Clustered Index가 없는 힙(Heap) 테이블에 Bulk Insert 명령을 이용하여 로딩할 경우, TABLOCK의 옵션 설정에 따라 3배 정도의 속도 차이가 있습니다하지만일괄 처리 크기(Rows Per Batch) 설정은 성능에 별 영향을 미치지 않습니다(34 : 33)

TABLOCK 옵션은 Bulk Insert 작업 수행 시 해당 테이블에 테이블 수준의 잠금을 설정함으로써하위 수준의 잠금 사용 시 발생하는 잠금 경합(Escalation)을 줄일 수 있을 뿐만 아니라 잠금을 설정하고 해제하는 단계를 줄여주기 때문에 처리 성능이 크게 향상될 수 있습니다(옵션 적용 전 - 109옵션 적용 - 34) 하지만이 옵션을 적용하여 로딩할 경우에는 WITH (NOLOCK) 옵션 또는 WITH (READUNCOMMITTED) 옵션을 사용하더라도 로딩 중에 해당 테이블의 데이터를 읽을 수 없습니다따라서 로딩 중에 다른 부분에서 사용되는 테이블인 경우에는 이 옵션을 적용할 경우 블로킹을 발생시킬 수 있기 때문에 주의해야 합니다.

 

 

 

 

 

 

Clustered Index가 설정되어 있는 테이블인 경우에는 Heap 테이블과는 달리 몇 가지 옵션을 더 설정할 수 있습니다.

우선 옵션 없이 단순히 Bulk Insert를 수행할 경우입력된 데이터에 대해 인덱스 구성 작업을 수행해야 하기 때문에 힙 테이블의 로딩과 비교했을 때 훨씬 더 많은 시간이 소요됩니다(Heap - 109, Clustered Index - 219)

일괄 처리 크기(Rows Per Batch) 100,000건으로 설정하게 되면 전체 건(10,000,000)의 인덱스를 한 번에 구성하는 대신 100,000건씩 나누어서 구성하기 때문에 처리 시간이 단축될 수 있습니다(일괄 처리 - 219, RPB 100,000 168)

만약 입력되는 데이터가 적재될 테이블의 Clustered 열과 동일한 순서로 정렬된 데이터인 경우에는ORDER(열 이름 [ASC | DESC]) 옵션을 이용하여 처리 시간을 단축 시킬 수 있습니다본 테스트에서는 텍스트 파일의 첫 번째 열로 정렬된 데이터이며이 데이터가 테이블의 SEQ열로 입력되기 때문에 ORDER 옵션을 적용할 경우처리 시간이 단축됩니다(옵션 미 적용 - 219, ORDER 옵션 적용 - 141)

또한 Heap에서와 마찬가지로 TABLOCK 옵션을 설정하여 처리할 경우처리 시간이 크게 단축됩니다. 10,000,000건의 텍스트 파일에 대해 아무런 옵션 없이 Bulk Insert 작업을 수행한 경우에 비해 ORDER, TABLOCK 옵션을 이용하여 처리한 수행 시간이 6배 정도 빠르게 나타났습니다(219 : 37)

 

 

참고로이러한 사항은 BULK INSERT 명령뿐만 아니라 SSIS(Integration Services) 패키지의 데이터 로딩 작업에서도 설정할 수 있는 사항입니다.

 

- OLE DB 대상에서 빠른 로드 설정 후고급 OLE DB 대상 편집기 중 FastLoadOptions 부분에서 설정

    

 

- SQL Server 대상의 고급 Server 대상 편집기 중BulkInsertOrder 부분에서 설정

   

 

 

 

 

본 게시판에 실린 글은 누구나 복사하셔서 이용하셔도 되지만반드시 출처(SQLLeader.com및 글의 링크를 밝혀주셔야 합니다. 

'SQL' 카테고리의 다른 글

Alias(별칭) "AS"  (0) 2011.05.02
Case When문  (0) 2011.05.02
virtual private network의 약자로, 우리말로 가상사설망이라고 한다.

VPN이란 인터넷망과 같은 공중망을 사설망처럼 이용해 회선 비용을 크게 절감할 수 있는 기업통신 서비스.

인터넷망을 전용선처럼 사용할 수 있도록 특수통신체계와 암호화기법을 제공하는 서비스로 기업 본사와 지사 또는 지사간에 전용망을 설치한 것과 같은 효과를 거둘 수 있으며, 전용선에 비해 20∼80% 이상의 비용을 줄일 수 있다. 

뿐만 아니라 사용자의 이동성 보장과 편리한 네트워크 구성 등이 장점이 있다. 그러나 VPN 구축을 위해서는 데이터암호화하는 보안기술이 뒷받침돼야 한다. 

가상사설망서비스는 미국에서 1980년 말부터 시작된 이후에 미국의 US Sprint와 AT&T에 의해 급속히 확산 보급되었다. 국내에 도입된 것은 지난 98년이며 VPN의 약점이던 보안문제가 해결되면서 서비스의 확산 속도가 더욱 빨라지고 있다.

VPN모든 회사들이 저마다 개별적으로 회선을 임차하는 것보다 공중망을 공유함으로써 비용은 낮추면서도 전용회선과 거의 동등한 서비스를 제공하려는 아이디어에서 출발하였다. 

VPN은 공중망을 통해 데이터를 송신하기 전에 데이터를 암호화하고, 수신측에서 이를 복호화한다.

마이크로소프트, 3Com 등 몇몇 회사들이 PPTP (Point-to-Point Tunneling Protocol)라는 표준 프로토콜을 제안하였으며, 마이크로소프트는 이 프로토콜을 윈도우NT 서버에 내장시켰다. 
출처 :  네이버 지식사전

'기타' 카테고리의 다른 글

넥서스 S 바이너리 올리기  (0) 2012.11.25
[Hudson] 자동 빌드 설정 방법  (0) 2012.08.10
SVN GUI TOOL[SVN Tool - RapidSVN 사용법]  (0) 2011.02.09
SVN  (0) 2011.02.09
MMAP  (0) 2011.01.27

+ Recent posts