public static void testBrake(){
ScheduledExecutorService executorService = new ScheduledThreadPoolExecutor(1);
executorService.scheduleWithFixedDelay(new Runnable() {
@SneakyThrows
@Override
public void run(){
ClassPathResource classPathResource = new ClassPathResource("test/ezCar");
InputStream inputStream = classPathResource.getInputStream();
InputStreamReader isr = new InputStreamReader(inputStream);
BufferedReader br = new BufferedReader(isr);
String data = null;
String B1 = "";
String B2 = "";
while((data = br.readLine()) != null) {
if(data.contains("B1")){
B1 = data;
}else if(data.contains("B2")){
B2 = data;
}
}
redisComponent.getAndSet("B1",B1);
redisComponent.getAndSet("B2",B2);
br.close();
isr.close();
inputStream.close();
}
}, 0, 5, TimeUnit.SECONDS);
}



