# 1. ***多线程的配置文件 AsyncConfiguration***
@Configuration
@EnableAsync
public class AsyncConfiguration {
@Bean("doExecutor")
public Executor doExecutor() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
executor.setCorePoolSize(10);
executor.setMaxPoolSize(20);
executor.setQueueCapacity(500);
executor.setKeepAliveSeconds(60);
executor.setThreadNamePrefix("do-executor-");
executor.setRejectedExecutionHandler(new ThreadPoolExecutor.DiscardPolicy());
executor.initialize();
return executor;
}
}
## 2. 方法调用只需在该方法上添加注解,命名和注入bean相同即可 @Async("doExecutor")
@Slf4j
@Service
public class AsyncBasicService extends BaseController {
@Autowired
SftpConfiguration sftpConfiguration;
@Async("doExecutor")
@Transactional(rollbackFor = Exception.class)
public FTPClient getFileWriter( Long classId, List<TableFieldDto> fieldDtoList, List<Map<String, Object>> tableData,String userId) {
String fileName = DateUtils.format(new Date(), DateUtils.DATE_EXPORT_PATTERN) + ".txt";
File directory = new File(sftpConfiguration.getSourceDirectory());
if (!directory.exists()) {
directory.mkdir();
}
FTPClient ftpClient = null;
FileWriter fw = null;
try {
File file = new File(sftpConfiguration.getSourceDirectory() + fileName);
fw = new FileWriter(file);
log.info("每次写入文件的数据量是---------------------------------" + tableData.size());
for (Map<String, Object> tableDatum : tableData) {
int size = fieldDtoList.size();
StringBuilder str = new StringBuilder();
str.append("\r\n");
fw.write(str.toString());
}
fw.flush();
file.getName());
} catch (IOException e) {
e.printStackTrace();
}finally {
if (fw != null) {
try {
fw.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
return ftpClient;
}
}
## 方法调用
private void upload() {
asyncBasicService.getFileWriter(newDataset.getClassId(), fieldDtoList, tableData,newDataset.getUserId());
}