我想为Android应用程序创建一个自定义记录器。当应用程序生成大量信息时,日志记录应在单独的线程中完成。我不想使用Android日志,因为我需要以特定格式编写日志。多个线程将同时写入日志文件,因此我使用了一个队列来保存日志消息
这是我的代码
Queue<LogEntry> logQueue = new LinkedBlockingQueue<LogEntry>();
LogWritterThread logWritterThread = new LogWritterThread();
// to queue the log messages
public void QueueLogEntry(String message)
{
LogEntry le = new LogEntry(message);
{
logQueue.add(le);
logQueue.notifyAll();
}
logWritterThread.start();
}
class LogWritterThread extends Thread
{
public void run()
{
try
{
while(true)
{
//thread waits until there are any logs to write in the queue
if(logQueue.peek() == null)
synchronized(logQueue){
logQueue.wait();
}
if(logQueue.peek() != null)
{
LogEntry logEntry;
synchronized(logQueue){
logEntry = logQueue.poll();
}
// write the message to file
}
if(Thread.interrupted())
break;
}
}
catch (InterruptedException e)
{
}
}
}
这段代码有什么问题吗?或创建日志记录队列的更好方法
谢谢,阿努吉
Java BlockingQueue实现已经内置了同步问题。使用wait,notify和synced是多余的,因此不需要。
尝试模仿BlockingQueue javadoc中提供的Producer / Consumer示例
class LogEntry {
private final String message;
LogEntry(String msg) {
message = msg;
}
}
class LogProducer {
private final BlockingQueue<LogEntry> queue;
LogProducer(BlockingQueue<LogEntry> q) {
queue = q;
}
public void log(String msg) {
queue.put(new LogEntry(msg));
}
}
class LogConsumer implements Runnable {
private final BlockingQueue<LogEntry> queue;
LogConsumer(BlockingQueue<LogEntry> q) {
queue = q;
}
public void run() {
try {
while(true) {
LogEntry entry = queue.take();
// do something with entry
}
} catch(InterruptedException ex) {
// handle
}
}
}
class Setup {
public static void main(String[] args) {
BlockingQueue<LogEntry> queue = new LinkedBlockingQueue<LogEntry>();
LogConsumer c = new LogConsumer(queue);
new Thread(c).start();
LogProducer p = new LogProducer(queue);
p.log("asynch");
p.log("logging");
}
}
本文收集自互联网,转载请注明来源。
如有侵权,请联系 [email protected] 删除。
我来说两句