Реализация многопоточной работы с помощью очередей.

Описание проекта: Есть базовый интерфейс OperationQueue, целью которого является обработка Operation. OperationQueue может обрабатывать Operation в несколько потоков. Operation должны обрабатываться только, если OperationQueue активна. В противном случе все операции ждут возобновления работы. У OperationQueue можно изменить количество активных потоков в любое время.
Есть интерфейс Operation, целью которого является выполнение конкретной задачи. Operation может быть в одном из 3 статусов: ready - готова к выполнению executing - выполняется finished - выполнена

OperationQueue может выполнять только те операции, которые готовы к выполнению(ready). Каждая операция может зависеть от других операций. Операция не может быть взята в работу до тех пор, пока не завершены те операции от которых зависит текущая.

Операции могут выполняться на разных OperationQueue. Ниже представлены базовые интерфейсы:

interface OperationQueue { void getThreadsCount()
void setThreadsCount(Int threads)bool isActive()void setActive(bool active)void addOperation(Operation operation) void addOperations(Operation... operations) void cancel(Operation operation)
void cancelAll() }
interface Operation { bool isReady()
bool isExecuting()bool isFinished()void start()void addDependency(Operation operation) void cancel()
}

Как использовать Operation и OperationQueue:
OperationQueue queue = new ...(); Operation foo = new PrintFooOperation() {
void start() {print('foo print')
} };
Operation bar = new PrintBarOperation() { void start() {
print('bar print') }
};bar.addDependency(foo)
queue.addOperations(foo, bar)// foo print// bar print

Организация заказчика: Naumen

Контакты представителя заказчика: Кошелев Антон Александрович, Anton.Koshelev@urfu.ru, +7(912) 248-42-74