package com.test;
?
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
?
import java.io.*;
import java.nio.ByteBuffer;
import java.util.Scanner;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
?
public class Test {
? ? public static void main(String[] args) throws FileNotFoundException {
?
? ? ? ? File file = new File("d:\\12bb.eif");
? ? ? ? FileInputStream fis = new FileInputStream(file);
? ? ? ? FileOutputStream fos = new FileOutputStream("d:\\ddxc\\bqb.eif");
?
? ? ? ? BufferedInputStream bis = new BufferedInputStream(fis);
? ? ? ? BufferedOutputStream bos = new BufferedOutputStream(fos);
? ? ? ? String fileName = file.getName();
?
? ? ? ? ExecutorService pool = Executors.newFixedThreadPool(30);//創(chuàng)建線程池，可自行定義
? ? ? ? Task task = new Task(true, bis, bos, fileName);
? ? ? ? pool.execute(task);
? ? ? ? Scanner scanner = new Scanner(System.in);//TODO 輸入文字并敲回車，開啟一個(gè)新線程控制文件的上傳、暫停（在上傳和暫停間來回切換）
? ? ? ? while (scanner.hasNextLine()) {
? ? ? ? ? ? String s = scanner.nextLine();
? ? ? ? ? ? pool.execute(task);
? ? ? ? }
?
?
? ? }
?
}
?
@Data
@AllArgsConstructor
@NoArgsConstructor
class Task implements Runnable {
?
? ? private volatile Boolean flag = true;//控制文件繼續(xù)、暫停上傳的標(biāo)識(shí)，true為繼續(xù)上傳，false暫停上傳
? ? private BufferedInputStream bis;
? ? private BufferedOutputStream bos;
? ? private String flagName;//監(jiān)聽器，一般設(shè)置為用戶編號(hào)+文件名，防止不同用戶上傳相同為文件。但本demo只以文件名作為監(jiān)聽器
?
? ? @Override
? ? public void run() {
? ? ? ? String threadName = Thread.currentThread().getName();
? ? ? ? //TODO 對(duì)線程的后綴名進(jìn)行判斷，如果是不是第一個(gè)線程，則判斷為控制線程
? ? ? ? if (!threadName.endsWith("1")) {
? ? ? ? ? ? this.flag = !flag;
? ? ? ? }
? ? ? ? synchronized (flagName) {
? ? ? ? ? ? if (!threadName.endsWith("1")) {
?
? ? ? ? ? ? ? ? System.out.println(threadName + "控制線程開始運(yùn)行");
?
? ? ? ? ? ? ? ? if (flag) {
? ? ? ? ? ? ? ? ? ? flagName.notifyAll();
? ? ? ? ? ? ? ? ? ? System.out.println("繼續(xù)傳輸文件");
? ? ? ? ? ? ? ? }
?
? ? ? ? ? ? } else {
?
? ? ? ? ? ? ? ? try {
?
? ? ? ? ? ? ? ? ? ? System.out.println(threadName + "傳輸線程開始運(yùn)行");
? ? ? ? ? ? ? ? ? ? int len = 0;
? ? ? ? ? ? ? ? ? ? byte[] cbuf = new byte[1024];
? ? ? ? ? ? ? ? ? ? while ((len = bis.read(cbuf, 0, cbuf.length)) != -1) {
? ? ? ? ? ? ? ? ? ? ? ? if (!flag) {
? ? ? ? ? ? ? ? ? ? ? ? ? ? System.out.println("文件通道阻塞中");
? ? ? ? ? ? ? ? ? ? ? ? ? ? flagName.wait();
? ? ? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? ? ? ? ? bos.write(cbuf, 0, len);
? ? ? ? ? ? ? ? ? ? ? ? bos.flush();
?
? ? ? ? ? ? ? ? ? ? ? ? Thread.sleep(10);
? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? ? ? System.out.println("文件傳輸完畢");
? ? ? ? ? ? ? ? ? ? bis.close();
? ? ? ? ? ? ? ? ? ? bos.close();
? ? ? ? ? ? ? ? ? ? System.exit(1);
? ? ? ? ? ? ? ? } catch (Exception e) {
? ? ? ? ? ? ? ? ? ? e.printStackTrace();
? ? ? ? ? ? ? ? }
? ? ? ? ? ? }
? ? ? ? ? ? System.out.println(threadName + "控制線程運(yùn)行完畢");
? ? ? ? }
? ? }
}