Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
冰 河
mykit-concurrent-jdk
提交
6018f9eb
M
mykit-concurrent-jdk
项目概览
冰 河
/
mykit-concurrent-jdk
10 个月 前同步成功
通知
26
Star
22
Fork
10
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
DevOps
流水线
流水线任务
计划
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
M
mykit-concurrent-jdk
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
DevOps
DevOps
流水线
流水线任务
计划
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
流水线任务
提交
Issue看板
前往新版Gitcode,体验更适合开发者的 AI 搜索 >>
提交
6018f9eb
编写于
9月 26, 2022
作者:
冰 河
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
提交自定义线程池源码
上级
4e700d1a
变更
2
隐藏空白更改
内联
并排
Showing
2 changed file
with
86 addition
and
0 deletion
+86
-0
mykit-concurrent-threadpool/src/main/java/io/binghe/concurrent/policy/RejectHandler.java
.../main/java/io/binghe/concurrent/policy/RejectHandler.java
+33
-0
mykit-concurrent-threadpool/src/main/java/io/binghe/concurrent/queue/BlockingQueue.java
...c/main/java/io/binghe/concurrent/queue/BlockingQueue.java
+53
-0
未找到文件。
mykit-concurrent-threadpool/src/main/java/io/binghe/concurrent/policy/RejectHandler.java
0 → 100644
浏览文件 @
6018f9eb
/**
* Copyright 2020-9999 the original author or authors.
* <p>
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
* <p>
* http://www.apache.org/licenses/LICENSE-2.0
* <p>
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package
io.binghe.concurrent.policy
;
import
io.binghe.concurrent.queue.BlockingQueue
;
/**
* @author binghe(公众号:冰河技术)
* @version 1.0.0
* @description 拒绝策略接口
*/
@FunctionalInterface
public
interface
RejectHandler
<
T
>
{
/**
* 拒绝任务回调接口
*/
void
reject
(
BlockingQueue
<
T
>
queue
,
T
task
);
}
mykit-concurrent-threadpool/src/main/java/io/binghe/concurrent/queue/BlockingQueue.java
0 → 100644
浏览文件 @
6018f9eb
/**
* Copyright 2020-9999 the original author or authors.
* <p>
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
* <p>
* http://www.apache.org/licenses/LICENSE-2.0
* <p>
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package
io.binghe.concurrent.queue
;
import
java.util.concurrent.TimeUnit
;
/**
* @author binghe(公众号:冰河技术)
* @version 1.0.0
* @description 自定义阻塞队列接口
*/
public
interface
BlockingQueue
<
T
>
{
/**
* 超时获取并移除队列数据
*/
T
poll
(
long
timeout
,
TimeUnit
timeUnit
);
/**
* 阻塞获取并移除队列数据
*/
T
take
();
/**
* 向队列中添加元素
*/
void
put
(
T
task
);
/**
* 向队列中超时添加元素
*/
boolean
offer
(
T
task
,
long
time
,
TimeUnit
timeUnit
);
/**
* 返回队列中元素的个数
*/
int
size
();
}
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录