• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

Java VarHandle类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中java.lang.invoke.VarHandle的典型用法代码示例。如果您正苦于以下问题:Java VarHandle类的具体用法?Java VarHandle怎么用?Java VarHandle使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



VarHandle类属于java.lang.invoke包,在下文中一共展示了VarHandle类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: tryOnNext

import java.lang.invoke.VarHandle; //导入依赖的package包/类
public static <T> boolean tryOnNext(ConditionalSubscriber<T> actual, Object target, VarHandle WIP, VarHandle ERRORS, T item) {
    if ((int)WIP.getAcquire(target) == 0 && WIP.compareAndSet(target, 0, 1)) {
        boolean b = actual.tryOnNext(item);
        if (!WIP.compareAndSet(target, 1, 0)) {
            Throwable ex = ExceptionHelper.terminate(target, ERRORS);
            if (ex == null) {
                actual.onComplete();
            } else {
                actual.onError(ex);
            }
            return false;
        }
        return b;
    }
    return false;
}
 
开发者ID:akarnokd,项目名称:Reactive4JavaFlow,代码行数:17,代码来源:HalfSerializer.java


示例2: push

import java.lang.invoke.VarHandle; //导入依赖的package包/类
/**
 * Pushes a task. Call only by owner in unshared queues.
 *
 * @param task the task. Caller must ensure non-null.
 * @throws RejectedExecutionException if array cannot be resized
 */
final void push(ForkJoinTask<?> task) {
    int s = top; ForkJoinTask<?>[] a; int al, d;
    if ((a = array) != null && (al = a.length) > 0) {
        int index = (al - 1) & s;
        ForkJoinPool p = pool;
        top = s + 1;
        QA.setRelease(a, index, task);
        if ((d = base - s) == 0 && p != null) {
            VarHandle.fullFence();
            p.signalWork();
        }
        else if (d + al == 1)
            growArray();
    }
}
 
开发者ID:AdoptOpenJDK,项目名称:openjdk-jdk10,代码行数:22,代码来源:ForkJoinPool.java


示例3: growArray

import java.lang.invoke.VarHandle; //导入依赖的package包/类
/**
 * Initializes or doubles the capacity of array. Call either
 * by owner or with lock held -- it is OK for base, but not
 * top, to move while resizings are in progress.
 */
final ForkJoinTask<?>[] growArray() {
    ForkJoinTask<?>[] oldA = array;
    int oldSize = oldA != null ? oldA.length : 0;
    int size = oldSize > 0 ? oldSize << 1 : INITIAL_QUEUE_CAPACITY;
    if (size < INITIAL_QUEUE_CAPACITY || size > MAXIMUM_QUEUE_CAPACITY)
        throw new RejectedExecutionException("Queue capacity exceeded");
    int oldMask, t, b;
    ForkJoinTask<?>[] a = array = new ForkJoinTask<?>[size];
    if (oldA != null && (oldMask = oldSize - 1) > 0 &&
        (t = top) - (b = base) > 0) {
        int mask = size - 1;
        do { // emulate poll from old array, push to new array
            int index = b & oldMask;
            ForkJoinTask<?> x = (ForkJoinTask<?>)
                QA.getAcquire(oldA, index);
            if (x != null &&
                QA.compareAndSet(oldA, index, x, null))
                a[b & mask] = x;
        } while (++b != t);
        VarHandle.releaseFence();
    }
    return a;
}
 
开发者ID:AdoptOpenJDK,项目名称:openjdk-jdk10,代码行数:29,代码来源:ForkJoinPool.java


示例4: pop

import java.lang.invoke.VarHandle; //导入依赖的package包/类
/**
 * Takes next task, if one exists, in LIFO order.  Call only
 * by owner in unshared queues.
 */
final ForkJoinTask<?> pop() {
    int b = base, s = top, al, i; ForkJoinTask<?>[] a;
    if ((a = array) != null && b != s && (al = a.length) > 0) {
        int index = (al - 1) & --s;
        ForkJoinTask<?> t = (ForkJoinTask<?>)
            QA.get(a, index);
        if (t != null &&
            QA.compareAndSet(a, index, t, null)) {
            top = s;
            VarHandle.releaseFence();
            return t;
        }
    }
    return null;
}
 
开发者ID:AdoptOpenJDK,项目名称:openjdk-jdk10,代码行数:20,代码来源:ForkJoinPool.java


示例5: tryConvertToWriteLock

import java.lang.invoke.VarHandle; //导入依赖的package包/类
/**
 * If the lock state matches the given stamp, atomically performs one of
 * the following actions. If the stamp represents holding a write
 * lock, returns it.  Or, if a read lock, if the write lock is
 * available, releases the read lock and returns a write stamp.
 * Or, if an optimistic read, returns a write stamp only if
 * immediately available. This method returns zero in all other
 * cases.
 *
 * @param stamp a stamp
 * @return a valid write stamp, or zero on failure
 */
public long tryConvertToWriteLock(long stamp) {
    long a = stamp & ABITS, m, s, next;
    while (((s = state) & SBITS) == (stamp & SBITS)) {
        if ((m = s & ABITS) == 0L) {
            if (a != 0L)
                break;
            if ((next = tryWriteLock(s)) != 0L)
                return next;
        }
        else if (m == WBIT) {
            if (a != m)
                break;
            return stamp;
        }
        else if (m == RUNIT && a != 0L) {
            if (casState(s, next = s - RUNIT + WBIT)) {
                VarHandle.storeStoreFence();
                return next;
            }
        }
        else
            break;
    }
    return 0L;
}
 
开发者ID:AdoptOpenJDK,项目名称:openjdk-jdk10,代码行数:38,代码来源:StampedLock.java


示例6: testInstanceFinalFieldUnsupported

import java.lang.invoke.VarHandle; //导入依赖的package包/类
static void testInstanceFinalFieldUnsupported(VarHandleTestAccessLong recv, VarHandle vh) {
    checkUOE(() -> {
        vh.set(recv, 0xCAFEBABECAFEBABEL);
    });

    checkUOE(() -> {
        vh.setVolatile(recv, 0xCAFEBABECAFEBABEL);
    });

    checkUOE(() -> {
        vh.setRelease(recv, 0xCAFEBABECAFEBABEL);
    });

    checkUOE(() -> {
        vh.setOpaque(recv, 0xCAFEBABECAFEBABEL);
    });



}
 
开发者ID:AdoptOpenJDK,项目名称:openjdk-jdk10,代码行数:21,代码来源:VarHandleTestAccessLong.java


示例7: testStaticFinalFieldUnsupported

import java.lang.invoke.VarHandle; //导入依赖的package包/类
static void testStaticFinalFieldUnsupported(VarHandle vh) {
    checkUOE(() -> {
        vh.set(0xCAFEBABECAFEBABEL);
    });

    checkUOE(() -> {
        vh.setVolatile(0xCAFEBABECAFEBABEL);
    });

    checkUOE(() -> {
        vh.setRelease(0xCAFEBABECAFEBABEL);
    });

    checkUOE(() -> {
        vh.setOpaque(0xCAFEBABECAFEBABEL);
    });



}
 
开发者ID:AdoptOpenJDK,项目名称:openjdk-jdk10,代码行数:21,代码来源:VarHandleTestAccessLong.java


示例8: testInstanceFinalFieldUnsupported

import java.lang.invoke.VarHandle; //导入依赖的package包/类
static void testInstanceFinalFieldUnsupported(VarHandleTestAccessChar recv, VarHandle vh) {
    checkUOE(() -> {
        vh.set(recv, '\u4567');
    });

    checkUOE(() -> {
        vh.setVolatile(recv, '\u4567');
    });

    checkUOE(() -> {
        vh.setRelease(recv, '\u4567');
    });

    checkUOE(() -> {
        vh.setOpaque(recv, '\u4567');
    });



}
 
开发者ID:AdoptOpenJDK,项目名称:openjdk-jdk10,代码行数:21,代码来源:VarHandleTestAccessChar.java


示例9: testStaticFinalFieldUnsupported

import java.lang.invoke.VarHandle; //导入依赖的package包/类
static void testStaticFinalFieldUnsupported(VarHandle vh) {
    checkUOE(() -> {
        vh.set('\u4567');
    });

    checkUOE(() -> {
        vh.setVolatile('\u4567');
    });

    checkUOE(() -> {
        vh.setRelease('\u4567');
    });

    checkUOE(() -> {
        vh.setOpaque('\u4567');
    });



}
 
开发者ID:AdoptOpenJDK,项目名称:openjdk-jdk10,代码行数:21,代码来源:VarHandleTestAccessChar.java


示例10: testStaticFinalFieldUnsupported

import java.lang.invoke.VarHandle; //导入依赖的package包/类
static void testStaticFinalFieldUnsupported(VarHandle vh) {
    checkUOE(() -> {
        vh.set((short)0x4567);
    });

    checkUOE(() -> {
        vh.setVolatile((short)0x4567);
    });

    checkUOE(() -> {
        vh.setRelease((short)0x4567);
    });

    checkUOE(() -> {
        vh.setOpaque((short)0x4567);
    });



}
 
开发者ID:AdoptOpenJDK,项目名称:openjdk-jdk10,代码行数:21,代码来源:VarHandleTestAccessShort.java


示例11: testStaticFinalFieldUnsupported

import java.lang.invoke.VarHandle; //导入依赖的package包/类
static void testStaticFinalFieldUnsupported(VarHandle vh) {
    checkUOE(() -> {
        vh.set(0x89ABCDEF);
    });

    checkUOE(() -> {
        vh.setVolatile(0x89ABCDEF);
    });

    checkUOE(() -> {
        vh.setRelease(0x89ABCDEF);
    });

    checkUOE(() -> {
        vh.setOpaque(0x89ABCDEF);
    });



}
 
开发者ID:AdoptOpenJDK,项目名称:openjdk-jdk10,代码行数:21,代码来源:VarHandleTestAccessInt.java


示例12: testInstanceFinalFieldUnsupported

import java.lang.invoke.VarHandle; //导入依赖的package包/类
static void testInstanceFinalFieldUnsupported(VarHandleTestAccessByte recv, VarHandle vh) {
    checkUOE(() -> {
        vh.set(recv, (byte)0x23);
    });

    checkUOE(() -> {
        vh.setVolatile(recv, (byte)0x23);
    });

    checkUOE(() -> {
        vh.setRelease(recv, (byte)0x23);
    });

    checkUOE(() -> {
        vh.setOpaque(recv, (byte)0x23);
    });



}
 
开发者ID:AdoptOpenJDK,项目名称:openjdk-jdk10,代码行数:21,代码来源:VarHandleTestAccessByte.java


示例13: testStaticFinalFieldUnsupported

import java.lang.invoke.VarHandle; //导入依赖的package包/类
static void testStaticFinalFieldUnsupported(VarHandle vh) {
    checkUOE(() -> {
        vh.set((byte)0x23);
    });

    checkUOE(() -> {
        vh.setVolatile((byte)0x23);
    });

    checkUOE(() -> {
        vh.setRelease((byte)0x23);
    });

    checkUOE(() -> {
        vh.setOpaque((byte)0x23);
    });



}
 
开发者ID:AdoptOpenJDK,项目名称:openjdk-jdk10,代码行数:21,代码来源:VarHandleTestAccessByte.java


示例14: addThrowable

import java.lang.invoke.VarHandle; //导入依赖的package包/类
public static boolean addThrowable(Object target, VarHandle ERRORS, Throwable t) {
    for (;;) {
        Throwable a = (Throwable) ERRORS.getAcquire(target);
        if (a == TERMINATED) {
            return false;
        }
        Throwable b = CompositeThrowable.combine(a, t);
        if (ERRORS.compareAndSet(target, a, b)) {
            return true;
        }
    }
}
 
开发者ID:akarnokd,项目名称:Reactive4JavaFlow,代码行数:13,代码来源:ExceptionHelper.java


示例15: testTypes

import java.lang.invoke.VarHandle; //导入依赖的package包/类
@Test(dataProvider = "typesProvider")
public void testTypes(VarHandle vh, List<java.lang.Class<?>> pts) {
    assertEquals(vh.varType(), short.class);

    assertEquals(vh.coordinateTypes(), pts);

    testTypes(vh);
}
 
开发者ID:AdoptOpenJDK,项目名称:openjdk-jdk10,代码行数:9,代码来源:VarHandleTestByteArrayAsShort.java


示例16: onNext

import java.lang.invoke.VarHandle; //导入依赖的package包/类
public static <T> void onNext(Flow.Subscriber<T> actual, Object target, VarHandle WIP, VarHandle ERRORS, T item) {
    if ((int)WIP.getAcquire(target) == 0 && WIP.compareAndSet(target, 0, 1)) {
        actual.onNext(item);
        if (!WIP.compareAndSet(target, 1, 0)) {
            Throwable ex = ExceptionHelper.terminate(target, ERRORS);
            if (ex == null) {
                actual.onComplete();
            } else {
                actual.onError(ex);
            }
        }
    }
}
 
开发者ID:akarnokd,项目名称:Reactive4JavaFlow,代码行数:14,代码来源:HalfSerializer.java


示例17: onError

import java.lang.invoke.VarHandle; //导入依赖的package包/类
public static void onError(Flow.Subscriber<?> actual, Object target, VarHandle WIP, VarHandle ERRORS, Throwable t) {
    if (ExceptionHelper.addThrowable(target, ERRORS, t)) {
        if ((int) WIP.getAndAdd(target, 1) == 0) {
            Throwable ex = ExceptionHelper.terminate(target, ERRORS);
            actual.onError(ex);
            return;
        }
    }
    FolyamPlugins.onError(t);
}
 
开发者ID:akarnokd,项目名称:Reactive4JavaFlow,代码行数:11,代码来源:HalfSerializer.java


示例18: run

import java.lang.invoke.VarHandle; //导入依赖的package包/类
@Override
public void run() {
	VarHandle handler;
	try {
		handler = MethodHandles.lookup().in(Account.class).findVarHandle(Account.class, "amount", double.class);
		for (int i = 0; i < 10000; i++) {
			handler.getAndAdd(account, 100);
			account.unsafeAmount += 100;
		}
	} catch (NoSuchFieldException | IllegalAccessException e) {
		e.printStackTrace();
	}

}
 
开发者ID:PacktPublishing,项目名称:Java-9-Concurrency-Cookbook-Second-Edition,代码行数:15,代码来源:Incrementer.java


示例19: run

import java.lang.invoke.VarHandle; //导入依赖的package包/类
@Override
public void run() {
	VarHandle handler;
	try {
		handler = MethodHandles.lookup().in(Account.class).findVarHandle(Account.class, "amount", double.class);
		for (int i = 0; i < 10000; i++) {
			handler.getAndAdd(account, -100);
			account.unsafeAmount -= 100;
		}
	} catch (NoSuchFieldException | IllegalAccessException e) {
		e.printStackTrace();
	}
}
 
开发者ID:PacktPublishing,项目名称:Java-9-Concurrency-Cookbook-Second-Edition,代码行数:14,代码来源:Decrementer.java


示例20: tryUnpush

import java.lang.invoke.VarHandle; //导入依赖的package包/类
/**
 * Pops the given task only if it is at the current top.
 */
final boolean tryUnpush(ForkJoinTask<?> task) {
    int b = base, s = top, al; ForkJoinTask<?>[] a;
    if ((a = array) != null && b != s && (al = a.length) > 0) {
        int index = (al - 1) & --s;
        if (QA.compareAndSet(a, index, task, null)) {
            top = s;
            VarHandle.releaseFence();
            return true;
        }
    }
    return false;
}
 
开发者ID:AdoptOpenJDK,项目名称:openjdk-jdk10,代码行数:16,代码来源:ForkJoinPool.java



注:本文中的java.lang.invoke.VarHandle类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java LogHandler类代码示例发布时间:2022-05-22
下一篇:
Java UnknownBlockTagTree类代码示例发布时间:2022-05-22
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap