D:\Sam\InterviewsMaterial\SiteWorx\SiteWorxTest\src\java\multithread_reader_services\ThreadingUpdateTargetTable.java
 1 /*
 2  * To change this template, choose Tools | Templates
 3  * and open the template in the editor.
 4  */
 5 package multithread_reader_services;
 6 
 7 import  java.io.*;
 8 import java.text.*;
 9 import java.lang.*;
10 import java.util.*;
11 
12 /**
13  *
14  * @author sameldin
15  */
16 public class ThreadingUpdateTargetTable  extends Thread
17 {
18     byte [] targetByteArray = null;    
19     UpdateTargetTable updateTargetTableHandle = null;
20        
21     /** Creates a new instance of ThreadingUpdateTargetTable */
22     public ThreadingUpdateTargetTable(int startIndex, int lastIndex ,String streamName, byte [] targetByteArray)  
23     {
24          updateTargetTableHandle = new UpdateTargetTable(startIndex, lastIndex, streamName);
25          this.targetByteArray = targetByteArray;
26         
27     }
28     /**
29      *
30      */
31     public void run()
32     {
33          int result = updateTargetTableHandle.updateTable(targetByteArray);        
34     }
35     /**
36      *
37      */
38      public static void main (String[] args)
39     {
40          byte [] targetByteArray = new byte[1200];
41          
42          ThreadingUpdateTargetTable thread_A_1 
43                  = new ThreadingUpdateTargetTable(0, 99, MultithreadConstants.FILE_PATH + MultithreadConstants.FILE_A_NAME, targetByteArray);
44          thread_A_1.start();
45          //====================== 
46          ThreadingUpdateTargetTable thread_B_2 
47                  = new ThreadingUpdateTargetTable(100, 199, MultithreadConstants.FILE_PATH + MultithreadConstants.FILE_B_NAME, targetByteArray);
48          thread_B_2.start();
49          //======================
50          ThreadingUpdateTargetTable thread_C_3 
51                  = new ThreadingUpdateTargetTable(200,299, MultithreadConstants.FILE_PATH + MultithreadConstants.FILE_C_NAME, targetByteArray);
52          thread_C_3.start();
53          //======================
54          ThreadingUpdateTargetTable thread_D_4 
55                  = new ThreadingUpdateTargetTable(300,399, MultithreadConstants.FILE_PATH + MultithreadConstants.FILE_D_NAME, targetByteArray);
56          thread_D_4.start();
57          //======================
58          ThreadingUpdateTargetTable thread_E_5 
59                  = new ThreadingUpdateTargetTable(400,499, MultithreadConstants.FILE_PATH + MultithreadConstants.FILE_E_NAME, targetByteArray);
60          thread_E_5.start();
61          //======================
62          ThreadingUpdateTargetTable thread_F_6 
63                  = new ThreadingUpdateTargetTable(500,599, MultithreadConstants.FILE_PATH + MultithreadConstants.FILE_F_NAME, targetByteArray);
64          thread_F_6.start();
65          //======================
66          ThreadingUpdateTargetTable thread_G_7 
67                  = new ThreadingUpdateTargetTable(600,699, MultithreadConstants.FILE_PATH + MultithreadConstants.FILE_G_NAME, targetByteArray);
68          thread_G_7.start();
69          //======================
70          ThreadingUpdateTargetTable thread_H_8 
71                  = new ThreadingUpdateTargetTable(700,799, MultithreadConstants.FILE_PATH + MultithreadConstants.FILE_H_NAME, targetByteArray);
72          thread_H_8.start();
73          //======================
74          ThreadingUpdateTargetTable thread_I_9 
75                  = new ThreadingUpdateTargetTable(800,899, MultithreadConstants.FILE_PATH + MultithreadConstants.FILE_I_NAME, targetByteArray);
76          thread_I_9.start();
77          //======================
78          ThreadingUpdateTargetTable thread_J_10 
79                  = new ThreadingUpdateTargetTable(900,999, MultithreadConstants.FILE_PATH + MultithreadConstants.FILE_J_NAME, targetByteArray);
80          thread_J_10.start();
81          //======================
82          
83          
84          int forStopingDebugger = 0;
85     }    
86 }
87