Gfrktyl

Step 1: Get the total No of Record from Database. ie (Select count(*) from employee)  ie (example:  totalRecordsFromDB=121);

Step 2 :Equally share the data to thread ie (example :totalThreadSize=3)

Step 3 : calculate the start/end point and trigger the thread.

Step 4 : Based on the start/end i will trigger the thread.ie 

  (select * from employee where empid >=start and empid<=end)



import java.util.ArrayList;

import java.util.HashMap;

import java.util.List;

import java.util.Map;



/**

 * @author dhava

 *

 */

public class CoreLogic {



    /**

     * @param args

     */

    public static void main(String args) {

        // TODO Auto-generated method stub



        int totalRecordsFromDB=121;

        int totalThreadSize=3;

        int spanStart=1;

        int spanLimit=totalRecordsFromDB/totalThreadSize;

        int counter=1;

        Map<String,List<Integer>> result=new HashMap<String,List<Integer>>();

        List<Integer> sublist=new ArrayList<Integer>();

        int totalRecordForSpan=1;

        int startNode=0;

        int endNode=0;

        int spliter=1;



        for(int i=1;i<=totalRecordsFromDB;i++) {



            if(spanStart==totalRecordForSpan) {

                startNode=i;

                sublist=new ArrayList<Integer>();

                sublist.add(startNode);

            }

            else if(spanLimit==totalRecordForSpan && spliter!=totalThreadSize) {

                endNode=i;



                totalRecordForSpan=0;

                sublist.add(endNode);

                result.put("Split_"+spliter,sublist);

                spliter++;

                // <<start the thread >>

            }

            else if(totalRecordsFromDB==counter) {

                endNode=i;

                sublist.add(endNode);

                result.put("Split_"+spliter,sublist);

                //<< start the thread >>





            }

            totalRecordForSpan++;

            counter++;

        }

            System.out.println(result);

    }



}

{Split_3=[81, 121], Split_2=[41, 80], Split_1=[1, 40]}



Please refer the given below queries.

1. Is this design/code is good ? - I have thread Limit.

2. Is any other approach or design for better performance  ?

3. Is there any way in spring-batch to configure the thread?

Step 1: Get the total No of Record from Database. ie (Select count(*) from employee)  ie (example:  totalRecordsFromDB=121);

Step 2 :Equally share the data to thread ie (example :totalThreadSize=3)

Step 3 : calculate the start/end point and trigger the thread.

Step 4 : Based on the start/end i will trigger the thread.ie 

  (select * from employee where empid >=start and empid<=end)



import java.util.ArrayList;

import java.util.HashMap;

import java.util.List;

import java.util.Map;



/**

 * @author dhava

 *

 */

public class CoreLogic {



    /**

     * @param args

     */

    public static void main(String args) {

        // TODO Auto-generated method stub



        int totalRecordsFromDB=121;

        int totalThreadSize=3;

        int spanStart=1;

        int spanLimit=totalRecordsFromDB/totalThreadSize;

        int counter=1;

        Map<String,List<Integer>> result=new HashMap<String,List<Integer>>();

        List<Integer> sublist=new ArrayList<Integer>();

        int totalRecordForSpan=1;

        int startNode=0;

        int endNode=0;

        int spliter=1;



        for(int i=1;i<=totalRecordsFromDB;i++) {



            if(spanStart==totalRecordForSpan) {

                startNode=i;

                sublist=new ArrayList<Integer>();

                sublist.add(startNode);

            }

            else if(spanLimit==totalRecordForSpan && spliter!=totalThreadSize) {

                endNode=i;



                totalRecordForSpan=0;

                sublist.add(endNode);

                result.put("Split_"+spliter,sublist);

                spliter++;

                // <<start the thread >>

            }

            else if(totalRecordsFromDB==counter) {

                endNode=i;

                sublist.add(endNode);

                result.put("Split_"+spliter,sublist);

                //<< start the thread >>





            }

            totalRecordForSpan++;

            counter++;

        }

            System.out.println(result);

    }



}

{Split_3=[81, 121], Split_2=[41, 80], Split_1=[1, 40]}



Please refer the given below queries.

1. Is this design/code is good ? - I have thread Limit.

2. Is any other approach or design for better performance  ?

3. Is there any way in spring-batch to configure the thread?

Step 1: Get the total No of Record from Database. ie (Select count(*) from employee)  ie (example:  totalRecordsFromDB=121);

Step 2 :Equally share the data to thread ie (example :totalThreadSize=3)

Step 3 : calculate the start/end point and trigger the thread.

Step 4 : Based on the start/end i will trigger the thread.ie 

  (select * from employee where empid >=start and empid<=end)



import java.util.ArrayList;

import java.util.HashMap;

import java.util.List;

import java.util.Map;



/**

 * @author dhava

 *

 */

public class CoreLogic {



    /**

     * @param args

     */

    public static void main(String args) {

        // TODO Auto-generated method stub



        int totalRecordsFromDB=121;

        int totalThreadSize=3;

        int spanStart=1;

        int spanLimit=totalRecordsFromDB/totalThreadSize;

        int counter=1;

        Map<String,List<Integer>> result=new HashMap<String,List<Integer>>();

        List<Integer> sublist=new ArrayList<Integer>();

        int totalRecordForSpan=1;

        int startNode=0;

        int endNode=0;

        int spliter=1;



        for(int i=1;i<=totalRecordsFromDB;i++) {



            if(spanStart==totalRecordForSpan) {

                startNode=i;

                sublist=new ArrayList<Integer>();

                sublist.add(startNode);

            }

            else if(spanLimit==totalRecordForSpan && spliter!=totalThreadSize) {

                endNode=i;



                totalRecordForSpan=0;

                sublist.add(endNode);

                result.put("Split_"+spliter,sublist);

                spliter++;

                // <<start the thread >>

            }

            else if(totalRecordsFromDB==counter) {

                endNode=i;

                sublist.add(endNode);

                result.put("Split_"+spliter,sublist);

                //<< start the thread >>





            }

            totalRecordForSpan++;

            counter++;

        }

            System.out.println(result);

    }



}

{Split_3=[81, 121], Split_2=[41, 80], Split_1=[1, 40]}



Please refer the given below queries.

1. Is this design/code is good ? - I have thread Limit.

2. Is any other approach or design for better performance  ?

3. Is there any way in spring-batch to configure the thread?

Step 1: Get the total No of Record from Database. ie (Select count(*) from employee)  ie (example:  totalRecordsFromDB=121);

Step 2 :Equally share the data to thread ie (example :totalThreadSize=3)

Step 3 : calculate the start/end point and trigger the thread.

Step 4 : Based on the start/end i will trigger the thread.ie 

  (select * from employee where empid >=start and empid<=end)



import java.util.ArrayList;

import java.util.HashMap;

import java.util.List;

import java.util.Map;



/**

 * @author dhava

 *

 */

public class CoreLogic {



    /**

     * @param args

     */

    public static void main(String args) {

        // TODO Auto-generated method stub



        int totalRecordsFromDB=121;

        int totalThreadSize=3;

        int spanStart=1;

        int spanLimit=totalRecordsFromDB/totalThreadSize;

        int counter=1;

        Map<String,List<Integer>> result=new HashMap<String,List<Integer>>();

        List<Integer> sublist=new ArrayList<Integer>();

        int totalRecordForSpan=1;

        int startNode=0;

        int endNode=0;

        int spliter=1;



        for(int i=1;i<=totalRecordsFromDB;i++) {



            if(spanStart==totalRecordForSpan) {

                startNode=i;

                sublist=new ArrayList<Integer>();

                sublist.add(startNode);

            }

            else if(spanLimit==totalRecordForSpan && spliter!=totalThreadSize) {

                endNode=i;



                totalRecordForSpan=0;

                sublist.add(endNode);

                result.put("Split_"+spliter,sublist);

                spliter++;

                // <<start the thread >>

            }

            else if(totalRecordsFromDB==counter) {

                endNode=i;

                sublist.add(endNode);

                result.put("Split_"+spliter,sublist);

                //<< start the thread >>





            }

            totalRecordForSpan++;

            counter++;

        }

            System.out.println(result);

    }



}

{Split_3=[81, 121], Split_2=[41, 80], Split_1=[1, 40]}



Please refer the given below queries.

1. Is this design/code is good ? - I have thread Limit.

2. Is any other approach or design for better performance  ?

3. Is there any way in spring-batch to configure the thread?

Your Answer

StackExchange.ifUsing("editor", function () {
return StackExchange.using("mathjaxEditing", function () {
StackExchange.MarkdownEditor.creationCallbacks.add(function (editor, postfix) {
StackExchange.mathjaxEditing.prepareWmdForMathJax(editor, postfix, [["\$", "\$"]]);
});
});
}, "mathjax-editing");

StackExchange.ifUsing("editor", function () {
StackExchange.using("externalEditor", function () {
StackExchange.using("snippets", function () {
StackExchange.snippets.init();
});
});
}, "code-snippets");

StackExchange.ready(function() {
var channelOptions = {
tags: "".split(" "),
id: "196"
};
initTagRenderer("".split(" "), "".split(" "), channelOptions);

StackExchange.using("externalEditor", function() {
// Have to fire editor after snippets, if snippets enabled
if (StackExchange.settings.snippets.snippetsEnabled) {
StackExchange.using("snippets", function() {
createEditor();
});
}
else {
createEditor();
}
});

function createEditor() {
StackExchange.prepareEditor({
heartbeatType: 'answer',
autoActivateHeartbeat: false,
convertImagesToLinks: false,
noModals: true,
showLowRepImageUploadWarning: true,
reputationToPostImages: null,
bindNavPrevention: true,
postfix: "",
imageUploader: {
brandingHtml: "Powered by u003ca class="icon-imgur-white" href="https://imgur.com/"u003eu003c/au003e",
contentPolicyHtml: "User contributions licensed under u003ca href="https://creativecommons.org/licenses/by-sa/3.0/"u003ecc by-sa 3.0 with attribution requiredu003c/au003e u003ca href="https://stackoverflow.com/legal/content-policy"u003e(content policy)u003c/au003e",
allowUrls: true
},
onDemand: true,
discardSelector: ".discard-answer"
,immediatelyShowMarkdownHelp:true
});


}
});