Commit f3b6b18b by 吴博

feat: [1006727] 接口优化3月3

parent 1f97af23
...@@ -62,6 +62,8 @@ import org.springframework.beans.factory.annotation.Value; ...@@ -62,6 +62,8 @@ import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
import static com.pcloud.book.util.common.ThreadPoolUtils.BOOK_RECORD_POOL;
/** /**
* @ClassName com.pcloud.book.record.biz.impl.BookBrowseRecordBizImpl * @ClassName com.pcloud.book.record.biz.impl.BookBrowseRecordBizImpl
* @Author 吴博 * @Author 吴博
...@@ -104,6 +106,8 @@ public class BookBrowseRecordBizImpl implements BookBrowseRecordBiz { ...@@ -104,6 +106,8 @@ public class BookBrowseRecordBizImpl implements BookBrowseRecordBiz {
@Override @Override
@ParamLog("读者书籍埋点记录") @ParamLog("读者书籍埋点记录")
public void addBookRecord(BookBrowseRecord bookBrowseRecord) { public void addBookRecord(BookBrowseRecord bookBrowseRecord) {
//异步埋点
BOOK_RECORD_POOL.execute(() -> {
Long sceneId = bookBrowseRecord.getSceneId(); Long sceneId = bookBrowseRecord.getSceneId();
if (null == sceneId) { if (null == sceneId) {
return; return;
...@@ -115,6 +119,8 @@ public class BookBrowseRecordBizImpl implements BookBrowseRecordBiz { ...@@ -115,6 +119,8 @@ public class BookBrowseRecordBizImpl implements BookBrowseRecordBiz {
} }
bookBrowseRecord.setBookId(bookId); bookBrowseRecord.setBookId(bookId);
addBookRecord4BookId(bookBrowseRecord); addBookRecord4BookId(bookBrowseRecord);
});
} }
@Override @Override
......
...@@ -109,6 +109,12 @@ public class ThreadPoolUtils { ...@@ -109,6 +109,12 @@ public class ThreadPoolUtils {
*/ */
public static final ThreadPoolExecutor REMOTE_CALL_POOL = new ThreadPoolExecutor(8, 8, 0, TimeUnit.SECONDS, public static final ThreadPoolExecutor REMOTE_CALL_POOL = new ThreadPoolExecutor(8, 8, 0, TimeUnit.SECONDS,
new LinkedBlockingQueue<>(), new ThreadFactoryBuilder().setNameFormat("remote-call-pool-%d").build(), new ThreadPoolExecutor.CallerRunsPolicy()); new LinkedBlockingQueue<>(), new ThreadFactoryBuilder().setNameFormat("remote-call-pool-%d").build(), new ThreadPoolExecutor.CallerRunsPolicy());
/**
* 书刊记录埋点线程池
*/
public static final ThreadPoolExecutor BOOK_RECORD_POOL = new ThreadPoolExecutor(8, 8, 0, TimeUnit.SECONDS,
new LinkedBlockingQueue<>(), new ThreadFactoryBuilder().setNameFormat("book_record-pool-%d").build(), new ThreadPoolExecutor.CallerRunsPolicy());
} }
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment