Java добавление потоков Queue
У меня два класса, один ставит переменную в очередь другой забирает. Реализовать не могу, подскажите пожалуйста что не так? В Java совсем еще новичок.
//КЛАСС№1
package jdev.services;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Service;
import java.util.concurrent.BlockingDeque;
import java.util.concurrent.LinkedBlockingDeque;
@Service
public class DataPeekService {
private static final Logger log = LoggerFactory.getLogger( DataPeekService.class );
private BlockingDeque<Object> queue = new LinkedBlockingDeque<Object>( 100 );
private int putCount;
private long previous;
@Scheduled(fixedDelay = 1_000)
void put() throws InterruptedException {
int i = 5;
queue.put( i );
}
//____КЛАСС№2
package jdev.services;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Service;
import java.util.concurrent.BlockingDeque;
import java.util.concurrent.LinkedBlockingDeque;
@Service
public class DataSendService extends DataPeekService {
private static final Logger log = LoggerFactory.getLogger(DataPeekService.class);
private BlockingDeque<String> queue = new LinkedBlockingDeque<>(100);
private int putCount;
private long previous;
@Autowired
private DataPeekService dataPeekService;
@Scheduled(fixedDelay = 1_000)
void take() throws InterruptedException {
log.info("take tingai !!");
System.out.println( "Данные :" );
System.out.println(" ScheduledQueueService.take " + queue.poll());
}
}