Description
-
Assignment Policies
Collaboration Policy. This assignment must be done individually. It is ac-ceptable for students to collaborate in understanding the material but not in solving the problems or programming. Use of the Internet is allowed, but should not include searching for existing solutions.
Under absolutely no circumstances code can be exchanged between students of different groups. Excerpts of code presented in class can be used.
Assignments from previous offerings of the course must not be re-used. Violations will be penalized appropriately.
Late Policy. Late submissions are allowed. The policy is 2 points off for every hour past the deadline.
-
Concurrent File Writing
The idea behind this assignment is to get students familiar with the basics of threads in Java. The task itself is simple, but the implementation does involve some consideration about how threads are to be spawned, and also forces the student to think about the role each thread should play in the overall solution.
Students are asked to implement a method that reads a text file into memory, concurrently rearranges this buffer, and then writes the rearranged buffer into an new output file. Figure 1 depicts this architecture in the case that the rearrangement is performed by 5 threads (Note: this is just an example, your solution may require more or less than 5 threads; please read on). The input and output buffer are different buffers.
In this assignment, we will just be dealing with text files. A file will be seen as a sequence of fixed size “chunks”. In particular, the file size must be a multiple of the chunk size. The name of the file and the size of a chunk is specified by the user in stdin as a command line argument. Here is a sample execution:
CS511 – Concurrent Programming 2 CONCURRENT FILE WRITING
CS511 – Concurrent Programming 2 CONCURRENT FILE WRITING
00000111112222233333444445555566666777778888899999 the rearrangement pattern ’j h i e d c b a f g’ should produce
99999777778888844444333332222211111000005555566666
2.1 File Structure
This assignment consists of the following files:
-
Interval.java. Declares the Interval class.
-
TextSwap.java. Declares the TextSwap class. This class holds the main method from which the assignment is executed.
-
Swapper.java. Declares the Swapper class.
-
letters.txt. A sample text file.
2.1.1 TextSw p
The TextSwap class contains much of the logic for the assignment. It has the methods:
-
privatestaticString readFile (String f lename) throwsException
Th s m thod should read from a specified file by placing it o a String-Bu lder object and then returning the toStr g() of that object.
-
privatestaticInterval[] getIntervals (intnumChunks, intchunkS ze)
Th s m thod returns an array of “Intervals”. An interval is just a pair of integers that spe ify the start and end index of a chunk. These intervals will be delegated to the appropriate threads to ensure the reordering s
oper.
-
privatestaticchar[] runSwapper (String content, intchunkSize, intnumChunks)
Th s method does much of the actual logic of the class. It creates the ntervals, runs the Swapper threads, and returns the reordered buffer that will be wri en to the new file.
-
intprivatestaticvoidwriteToFile (String contents, intchunkSize,
numChunks) throwsException
This method writes the buffer to a new file.
-
publicstaticvoidmain (String [] args)
The main should parse two command line inputs, a chunk size and a filename. The size of the file and the number of chunks should then be calculated, and the new pattern of letters should be read from stdin. If the number of chunks is more than 26, then execution should halt with
CS511 – Concurrent Programming 4 SUBMISSION INSTRUCTIONS
an error message “Chunk size too small”. If the file size is not a multiple of the chunk size, then execution hould halt with an error message “File size mu t be a multiple of the chunk size”. Note that there may be other methods necessary to complete this class, but they can also be inlined into these methods.
2.1.2 Sw pper
This class, whi h should implement he Runnable interface, will write to the b ffer g ven its I e val. It has the fields offset, interval, content, buffer:
1 publicclassSwapper implementsRunnable {
-
intoffset ;
-
-
3
Interval interval ;
4
String content ;
-
-
privatechar[] buffer ;
-
…
-
}
Offset: spe ifies the starting index in the buffer where the content will be placed.
Interval: specifies the starting and ending index of the content in the original
file that is being swapped. Content: the entire original file in a String. Buffer: The shared char[] that the result is being written to.
-
publicvoidrun ()
Write the specified content into the buffer. Helper methods may be used to retrieve the content and insert it into the proper spot in the buffer.
2.1.3 Interval
This is exactly what you would expect from any “Pair” class. There is even a Pair class in the Java library that can be used instead.
-
Your Task
Implement Swapper.java and the methods runSwapper and getIntervals in file TextSwap.java.
-
Submission Instructions
Submit a zip file namedhw1.zip through Canvas containing all the files included in the stub but where all required operations have been implemented. Also include your name as a comment in the fileTextSwap.java.
4
