@EnableScheduling // 1.開啟定時任務
@EnableAsync // 2.開啟多線程
@Service
public class ChkMeetServiceImpl extends ServiceImpl<ChkMeetMapper, ChkMeet> implements ChkMeetService {
@Override
public void meetPublicity( Long meetId) throws SocketException {
ChkMeet chkMeet = chkMeetMapper.selectById(meetId);
ScheduledThreadPoolExecutor scheduled = new ScheduledThreadPoolExecutor(2);
scheduled.schedule(new Runnable() {
@Override
public void run() {
chkMeet.setWorkFlowState(3);
chkMeetMapper.updateById(chkMeet);
scheduled.shutdownNow();
}
}, 1, TimeUnit.MINUTES);//1表示執行任務的間隔時間,以分鍾為單位
}
}