package com.product.file.util; import java.util.LinkedList; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import com.product.core.entity.FieldSetEntity; import com.product.core.spring.context.SpringBeanUtil; import com.product.core.spring.context.SpringMVCContextHolder; import com.product.file.service.FileManagerService; import com.product.lucene.service.LuceneService; /** * 消息服务,添加消息,读取消息 * @author shicf * */ @Component public class CreateDocumentIndexThread { /**自已实例**/ private static CreateDocumentIndexThread createDocumentIndexThread; @Autowired public FileManagerService fileManagerService; /**内部线程**/ private SendMailThread sendMailThread=null; @Autowired public LuceneService luceneService; /** 生成的新消息队列**/ private static LinkedList documentIndexs=new LinkedList<>(); /** * 静态工厂方法 获取当前对象实例 多线程安全单例模式(使用双重同步锁) */ public static synchronized CreateDocumentIndexThread getInstance() { if (createDocumentIndexThread == null) { synchronized (CreateDocumentIndexThread.class) { if (createDocumentIndexThread == null) { createDocumentIndexThread=(CreateDocumentIndexThread) SpringBeanUtil.getBean("createDocumentIndexThread"); } } } createDocumentIndexThread.start(); return createDocumentIndexThread; } /** * 启动缓存的刷新线程 */ public void start() { if(sendMailThread ==null || sendMailThread.getState()== Thread.State.TERMINATED ) { sendMailThread=new SendMailThread(); sendMailThread.start(); SpringMVCContextHolder.getSystemLogger().info("Thread Of Refresh Cache Is Starting............."); } } /** * 把附件信息添加对列中 * @param user */ public synchronized void appendAttaInfo(FieldSetEntity documentIndex) { if(documentIndex!=null) { documentIndexs.add(documentIndex); } } /** * 取刷新表队表的第一个 * @return */ public synchronized void pop() { while(!documentIndexs.isEmpty()) { FieldSetEntity ff=documentIndexs.pop(); if(luceneService ==null ) { luceneService=(LuceneService) SpringBeanUtil.getBean("luceneService"); } ff.setValue("file", fileManagerService.getFile(ff.getString("attachment_uuid"))); luceneService.createdIndex(ff); } } /** * 内部线程,定时刷新缓存 * @author shicf * */ class SendMailThread extends Thread { @Override public void run() { try { while(true) { sleep(2000);// 执行间隔2s pop(); } } catch (InterruptedException e) { e.getStackTrace(); } } } }