D:\Sam\InterviewsMaterial\SiteWorx\SiteWorxTest\src\java\multithread_reader_services\ThreadingUpdateTargetTable.java |
1
2
3
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
15
16 public class ThreadingUpdateTargetTable extends Thread
17 {
18 byte [] targetByteArray = null;
19 UpdateTargetTable updateTargetTableHandle = null;
20
21
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