为了账号安全,请及时绑定邮箱和手机立即绑定

在多线程环境中使用模拟对象

在多线程环境中使用模拟对象

www说 2021-08-06 10:09:18
从jMock 2.6开始,我可以确保通过多个线程一致地看到我的模拟对象final Mockery mockery = new Mockery();mockery.setThreadingPolicy(new Synchroniser());使用jMock 2.5时,我有哪些选择(我遇到间歇性测试“碎片”)?特别是,使用?包装所有模拟对象方法调用是否足够(更新:不,不符合预期)synchronized?<T> T synchronizedMock(final T mock,        final Class<T> clazz) {    return (T) Proxy.newProxyInstance(Thread.currentThread().getContextClassLoader(),            new Class[] {clazz, CaptureControl.class},            (proxy, method, args) -> {                synchronized (mock) {                    return method.invoke(mock, args);                }            });}使用上述方法时,我遇到任何死锁的机会有多大?
查看完整描述

1 回答

?
叮当猫咪

TA贡献1776条经验 获得超12个赞

您是否考虑过使用 CGLib + ObjenesisHelper?CGLib 将允许您代理类和接口,而不仅仅是像 那样的接口java.lang.reflect.Proxy,并且 ObjenesisHelper 将允许您构造类的实例而无需调用构造函数。请参阅此处的 CGLib 示例和此处的 ObjenesisHelper 示例。


此外,您可以解包InvocationTargetException以确保代理实例抛出Exception由模拟类定义的预期。最后, usingregisterStaticCallbacks将确保绑定的方法拦截器存在于所有调用线程中。


public <T> T createProxy(final Class<? extends T> classToMock, final T mock) {

    final MethodInterceptor interceptor = (object, method, args, proxy) -> {

        synchronized (mock) {

            try {

                return method.invoke(mock, args);

            } catch (final InvocationTargetException e) {

                if (e.getCause() != null) {

                    throw e.getCause();

                }

                throw e;

            }

        }

    };


    final Enhancer enhancer = new Enhancer();

    enhancer.setSuperclass(classToMock);

    final Set<Class<?>> interfaces = new LinkedHashSet<>();

    if (classToMock.isInterface()) {

        interfaces.add(classToMock);

    }

    interfaces.addAll(Arrays.asList(classToMock.getInterfaces()));

    interfaces.add(CaptureControl.class);

    enhancer.setInterfaces(interfaces.toArray(new Class[interfaces.size()]));

    enhancer.setCallbackType(interceptor.getClass());


    final Class<?> proxyClass = enhancer.createClass();

    Enhancer.registerStaticCallbacks(proxyClass, new Callback[] { interceptor });

    return (T) ObjenesisHelper.newInstance(proxyClass);

}

使用上述方法时,我遇到任何死锁的机会有多大?


我不相信您提供的解决方案,也不相信上面建议的解决方案会遇到任何死锁(假设您的代码中没有死锁)。使用synchronizedwill 确保在任何给定时间只有一个线程可以操作模拟实例..并且除非 jmock 将方法调用委托给一个单独的线程(据我所知它没有),那么代码应该正常执行而不是阻塞。如果 jmock 要求您Mockery一次锁定所有实例,那么您可以传入一个专用对象进行同步,或者为所有代理拦截器提供可重入锁以共享。


查看完整回答
反对 回复 2021-08-06
  • 1 回答
  • 0 关注
  • 217 浏览

添加回答

举报

0/150
提交
取消
意见反馈 帮助中心 APP下载
官方微信