daxt/src/main/java/com/gz/job/MountArchiveFileJob.java

package com.gz.job;

import com.gz.config.MountArchiveFileConfig;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

import javax.annotation.PostConstruct;
import java.io.File;

/**
 * 挂挡文件
 *
 * @author LiuchangLan
 * @date 2021/3/16 13:30
 */
@Slf4j
@Component
public class MountArchiveFileJob {

    @PostConstruct
    public void HandelePDFJob() {
        MyThread thread = new MyThread();
        thread.start();
    }

    public class MyThread extends Thread{
        @Override
        public void run() {
            try {
                final File pdfFolder = MountArchiveFileConfig.PDFQueue.take();
                MountArchiveFileConfig.executorService.execute(() -> {
                    System.out.println(pdfFolder.getName());
                });
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }


}