正如其他人在评论中已经提到的那样,这是一种糟糕的方法,它不允许多个线程共享输入流并允许并发写入,这会导致文件损坏。
我在多线程分布式文件服务器项目中执行的一种方法是,我允许文件服务器的多线程执行,但只允许顺序执行线程。
我以这种方式进行编码,以确保线程以一种同步的方式(仅一种一种方式)访问输入流。这也没有在客户端破坏文件。而且,这在性能上也太惊人了。
注意,在对该答案采取任何措施之前:-
当时我对代码进行了基准测试,以确保我在答案中所说的确实对访问者/寻求者而言是最佳的。我认为这也是最佳情况,因为我有4个逻辑处理器(内核/
CPU),减少了多个线程的开销(尽管它们一次只能工作1个)。
人们会争辩说这是最糟糕的方法,或者是丑陋的方法,等等。但是我发现这对于文件服务器的播种非常有帮助。我的40 MB(大约)PDF文件 LinuxServer [Intel(R) Core(TM) 2 Duo CPU E4600 @ 2.40GHz processor, CPU(s): 2]
平均在4-5次执行测试中平均需要33-34秒的时间被复制到文件客户端。而当我增加线程数(8-10个线程)时,性能下降大约需要36-38秒。当我拥有单线程服务器时,情况相同,在45-50秒内复制了同一文件。随着线程数量的增加,性能得以提高,并且在4至6个线程范围内非常有效。
但是,显然维护多个线程会产生开销,而且人们会以为单个线程可以获胜, 但是 令人 惊讶 的是,在4-6个线程的情况下,结果是最佳的。
因此,我的建议是按照代码中所示的那样,通过4-6个线程对输入流进行顺序访问来进行处理。这是最佳选择,请相信我,我也可以与其他人争论多线程开销,我发现这种开销在4-6个线程的情况下是最佳的。
对于您的代码,我建议进行以下更改:-
InputStream is = new BufferedInputStream(new FileInputStream(file)); long len = new File(file).length(); System.out.println("Length of File = "+len); int numOFThreads=4; WorkerThread wt1=new WorkerThread(0,len/numOFThreads,fci,is,file); wt1.setName("Worker Thread 1"); WorkerThread wt2=new WorkerThread(len/numOFThreads+1,2*len/numOFThreads,fci,is,file); wt2.setName("Worker Thread 2"); WorkerThread wt3=new WorkerThread(2*len/numOFThreads+1,3*len/numOFThreads,fci,is,file); wt3.setName("Worker Thread 3"); WorkerThread wt4=new WorkerThread(3*len/numOFThreads+1,4*len/numOFThreads,fci,is,file); wt4.setName("Worker Thread 4"); wt1.start(); wt1.join(); wt2.start(); wt2.join(); wt3.start(); wt3.join(); wt4.start(); wt4.join();


