У меня есть поток, A
, который имеет список. Список содержит некоторые объекты. Теперь я хочу создать механизм, по которому я могу отправить сообщение в поток A
.
Thread A
работает в цикле (он не ждет и не спят).
Другой поток, B
, отправляет некоторое сообщение в поток A
, а поток A
опустошает все его очереди.
Как отправлять сообщения между потоками?
class A extends Thread {
List<Object> objs = something; //Init it
void run() {
while(true) {
//Body which works on objects.
//After receiving an external message, "A" should perform some action, for example, empty objects.
}
}
}
EDIT: Могу ли я сделать это так?
class A extends Thread {
List<Object> objs = something; //Init it
Boolean flag = false;
public void setFlag(boolean value) {
synchronized(flag) {
this.flag = value;
}
}
public void getFlag() {
synchronized(flag) {
return this.flag;
}
}
void run() {
while(true) {
//Body which works on objects.
//After receiving an external message, A should perform some action, for example, empty objects.
if (getFlag == true)
//Empty list
}
}
}