分批取数 多线程数据处理

*&---------------------------------------------------------------------*
*& Report  ZW_ARCHIVE_TEST
*&
*&---------------------------------------------------------------------*
*& In this connection, the following ABAP/4 statements are not allowed:
*& -  CALL SCREEN
*& -  CALL DIALOG
*& -  CALL TRANSACTION
*& -  SUBMIT
*& -  MESSAGE W... and MESSAGE I... and MESSAGE E...
*& -  COMMIT WORK, ROLLBACK WORK
*& -  COMMUNICATION RECEIVE
*& -  STOP
*& -  REJECT
*& -  EXIT FROM STEP-LOOP
*&---------------------------------------------------------------------*

REPORT  zw_archive_test.

DATA: taskname(10) TYPE n VALUE '1',"Task name administration
      snd_jobs    TYPE i VALUE 0,"Sent jobs
      rcv_jobs    TYPE i VALUE 0,"Received replies
       wa_indx    TYPE indx.

DATA: gt_log TYPE zesp1_message_tab_type_test WITH HEADER LINE.


SELECTION-SCREEN BEGIN OF BLOCK bl00 WITH FRAME TITLE text-000.
PARAMETERS: p_datum  LIKE sy-datum OBLIGATORY DEFAULT sy-datum,"归档时间点
            p_thrcnt LIKE sy-tabix OBLIGATORY DEFAULT 100,"每个线程处理数据记录条数

            p_maxcnt LIKE sy-tabix DEFAULT 1000."总共读取数据条数
SELECTION-SCREEN END OF BLOCK bl00.

START-OF-SELECTION.

CALL FUNCTION 'SPBT_INITIALIZE'
     EXPORTING
       group_name                           = serv_group"可不填
*     IMPORTING
*       MAX_PBT_WPS                          = 最大线程数
*       FREE_PBT_WPS                         = 空闲线程数
     EXCEPTIONS
       invalid_group_name                   = 1
       internal_error                       = 2
       pbt_env_already_initialized          = 3
       currently_no_resources_avail         = 4
       no_pbt_resources_found               = 5
       cant_init_different_pbt_groups       = 6
       OTHERS                               = 7
            . 

  PERFORM frm_do_it.

*&---------------------------------------------------------------------*
*&      Form  frm_do_it
*&---------------------------------------------------------------------*
*       分批取数 多线程数据处理
*----------------------------------------------------------------------*
FORM frm_do_it.
  DATA: ekko_cursor TYPE cursor,