本文整理了Java中org.apache.commons.lang3.mutable.MutableBoolean.getValue()
方法的一些代码示例,展示了MutableBoolean.getValue()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。MutableBoolean.getValue()
方法的具体详情如下:
包路径:org.apache.commons.lang3.mutable.MutableBoolean
类名称:MutableBoolean
方法名:getValue
[英]Gets the value as a Boolean instance.
[中]获取作为布尔实例的值。
代码示例来源:origin: neo4j/neo4j
private void logIndexProviderSummary( Map<IndexProviderDescriptor,List<IndexLogRecord>> indexProviders )
{
Set<String> deprecatedIndexProviders = Arrays.stream( GraphDatabaseSettings.SchemaIndex.values() )
.filter( GraphDatabaseSettings.SchemaIndex::deprecated )
.map( GraphDatabaseSettings.SchemaIndex::providerName )
.collect( Collectors.toSet() );
StringJoiner joiner = new StringJoiner( ", ", "Deprecated index providers in use: ",
". Use procedure 'db.indexes()' to see what indexes use which index provider." );
MutableBoolean anyDeprecated = new MutableBoolean();
indexProviders.forEach( ( indexProviderDescriptor, indexLogRecords ) ->
{
if ( deprecatedIndexProviders.contains( indexProviderDescriptor.name() ) )
{
anyDeprecated.setTrue();
int numberOfIndexes = indexLogRecords.size();
joiner.add( indexProviderDescriptor.name() + " (" + numberOfIndexes + (numberOfIndexes == 1 ? " index" : " indexes") + ")" );
}
} );
if ( anyDeprecated.getValue() )
{
userLog.info( joiner.toString() );
}
}
代码示例来源:origin: Netflix/conductor
private boolean verifyTaskInputParameters(ConstraintValidatorContext context, WorkflowDef workflow) {
MutableBoolean valid = new MutableBoolean();
valid.setValue(true);
if (workflow.getTasks() == null) {
return valid.getValue();
}
workflow.getTasks()
.stream()
.filter(workflowTask -> workflowTask.getInputParameters() != null)
.forEach(workflowTask -> {
List<String> errors = ConstraintParamUtil.validateInputParam(workflowTask.getInputParameters(), workflowTask.getName(), workflow);
errors.forEach(message -> context.buildConstraintViolationWithTemplate(message).addConstraintViolation());
if(errors.size() > 0) {
valid.setValue(false);
}
});
return valid.getValue();
}
代码示例来源:origin: neo4j/neo4j
/**
* @return true if instantiated tree needs to be rebuilt.
*/
private boolean instantiateTree() throws IOException
{
monitors.addMonitorListener( treeMonitor() );
GBPTree.Monitor monitor = monitors.newMonitor( GBPTree.Monitor.class );
MutableBoolean isRebuilding = new MutableBoolean();
Header.Reader readRebuilding =
headerData -> isRebuilding.setValue( headerData.get() == NEEDS_REBUILDING );
index = new GBPTree<>( pageCache, storeFile, new LabelScanLayout(), pageSize, monitor, readRebuilding,
needsRebuildingWriter, recoveryCleanupWorkCollector );
return isRebuilding.getValue();
}
代码示例来源:origin: neo4j/neo4j
@Test
void shouldCatchupRootWhenRootNodeHasTooNewGeneration() throws Exception
{
// given
long id = cursor.getCurrentPageId();
long generation = TreeNode.generation( cursor );
MutableBoolean triggered = new MutableBoolean( false );
Supplier<Root> rootCatchup = () ->
{
triggered.setTrue();
return new Root( id, generation );
};
// when
//noinspection EmptyTryBlock
try ( SeekCursor<KEY,VALUE> ignored = new SeekCursor<>( cursor, node, key( 0 ), key( 1 ), layout,
stableGeneration, unstableGeneration, generationSupplier, rootCatchup, generation - 1,
exceptionDecorator, 1 ) )
{
// do nothing
}
// then
assertTrue( triggered.getValue() );
}
代码示例来源:origin: neo4j/neo4j
assertTrue( triggered.getValue() );
代码示例来源:origin: neo4j/neo4j
assertTrue( triggered.getValue() );
代码示例来源:origin: org.apache.commons/commons-lang3
@Test
public void testGetSet() {
assertFalse(new MutableBoolean().booleanValue());
assertEquals(Boolean.FALSE, new MutableBoolean().getValue());
final MutableBoolean mutBool = new MutableBoolean(false);
assertEquals(Boolean.FALSE, mutBool.toBoolean());
assertFalse(mutBool.booleanValue());
assertTrue(mutBool.isFalse());
assertFalse(mutBool.isTrue());
mutBool.setValue(Boolean.TRUE);
assertEquals(Boolean.TRUE, mutBool.toBoolean());
assertTrue(mutBool.booleanValue());
assertFalse(mutBool.isFalse());
assertTrue(mutBool.isTrue());
mutBool.setValue(false);
assertFalse(mutBool.booleanValue());
mutBool.setValue(true);
assertTrue(mutBool.booleanValue());
mutBool.setFalse();
assertFalse(mutBool.booleanValue());
mutBool.setTrue();
assertTrue(mutBool.booleanValue());
}
代码示例来源:origin: fr.inria.eventcloud/eventcloud-deployment-cli
@Override
public void run() {
String line = null;
try {
while ((line = reader.readLine()) != null) {
if (!servicesDeployed.getValue()
&& line.contains(LOG_MANAGEMENT_WS_DEPLOYED)) {
servicesDeployed.setValue(true);
synchronized (servicesDeployed) {
servicesDeployed.notifyAll();
}
}
System.out.println("ECManagement " + line);
}
} catch (IOException ioe) {
ioe.printStackTrace();
}
}
});
代码示例来源:origin: org.neo4j/neo4j-kernel
private void logIndexProviderSummary( Map<IndexProviderDescriptor,List<IndexLogRecord>> indexProviders )
{
Set<String> deprecatedIndexProviders = Arrays.stream( GraphDatabaseSettings.SchemaIndex.values() )
.filter( GraphDatabaseSettings.SchemaIndex::deprecated )
.map( GraphDatabaseSettings.SchemaIndex::providerName )
.collect( Collectors.toSet() );
StringJoiner joiner = new StringJoiner( ", ", "Deprecated index providers in use: ",
". Use procedure 'db.indexes()' to see what indexes use which index provider." );
MutableBoolean anyDeprecated = new MutableBoolean();
indexProviders.forEach( ( indexProviderDescriptor, indexLogRecords ) ->
{
if ( deprecatedIndexProviders.contains( indexProviderDescriptor.name() ) )
{
anyDeprecated.setTrue();
int numberOfIndexes = indexLogRecords.size();
joiner.add( indexProviderDescriptor.name() + " (" + numberOfIndexes + (numberOfIndexes == 1 ? " index" : " indexes") + ")" );
}
} );
if ( anyDeprecated.getValue() )
{
userLog.info( joiner.toString() );
}
}
代码示例来源:origin: fr.inria.eventcloud/eventcloud-deployment-cli
while (!servicesDeployed.getValue()) {
try {
servicesDeployed.wait();
代码示例来源:origin: org.apache.bookkeeper/bookkeeper-server
if (isDuplicationFoundAndNotAllowed.getValue()) {
throw new BookieException.DiskPartitionDuplicationException();
代码示例来源:origin: com.netflix.conductor/conductor-common
private boolean verifyTaskInputParameters(ConstraintValidatorContext context, WorkflowDef workflow) {
MutableBoolean valid = new MutableBoolean();
valid.setValue(true);
if (workflow.getTasks() == null) {
return valid.getValue();
}
workflow.getTasks()
.stream()
.filter(workflowTask -> workflowTask.getInputParameters() != null)
.forEach(workflowTask -> {
List<String> errors = ConstraintParamUtil.validateInputParam(workflowTask.getInputParameters(), workflowTask.getName(), workflow);
errors.forEach(message -> context.buildConstraintViolationWithTemplate(message).addConstraintViolation());
if(errors.size() > 0) {
valid.setValue(false);
}
});
return valid.getValue();
}
代码示例来源:origin: pl.edu.icm.synat/synat-business-services-impl
@Override
public boolean hasAcceptableFiles(YElement yElement) {
final MutableBoolean result = new MutableBoolean(false);
ContentBrowser contentBrowser = new ContentBrowser();
contentBrowser.browse(yElement, new ContentWorker() {
@Override
public boolean doInDirectoryRecursively(YContentDirectory directory) {
return true;
}
@Override
public void doWithFile(YContentFile yfile) {
if (isFileAcceptable(yfile)) {
result.setValue(true);
}
}
});
return result.getValue();
}
}
代码示例来源:origin: org.neo4j/neo4j-kernel
/**
* @return true if instantiated tree needs to be rebuilt.
*/
private boolean instantiateTree() throws IOException
{
monitors.addMonitorListener( treeMonitor() );
GBPTree.Monitor monitor = monitors.newMonitor( GBPTree.Monitor.class );
MutableBoolean isRebuilding = new MutableBoolean();
Header.Reader readRebuilding =
headerData -> isRebuilding.setValue( headerData.get() == NEEDS_REBUILDING );
index = new GBPTree<>( pageCache, storeFile, new LabelScanLayout(), pageSize, monitor, readRebuilding,
needsRebuildingWriter, recoveryCleanupWorkCollector );
return isRebuilding.getValue();
}
代码示例来源:origin: kframework/k
if (isRecursive.getValue()) {
conn = "let rec ";
isLetRec = true;
代码示例来源:origin: kframework/k
if (!isProtecting.getValue()) {
nonProtectingSubsorts.add(subsort);
内容来源于网络,如有侵权,请联系作者删除!