- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 343 for notifyCh (0.13 sec)
-
maven-model-builder/src/main/java/org/apache/maven/model/building/ModelBuildingEventCatapult.java
* listener. * */ interface ModelBuildingEventCatapult { /** * Notifies the specified listener of the given event. * * @param listener The listener to notify, must not be {@code null}. * @param event The event to fire, must not be {@code null}. */ void fire(ModelBuildingListener listener, ModelBuildingEvent event);
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed Sep 06 08:39:32 UTC 2023 - 1.4K bytes - Viewed (0) -
platforms/core-runtime/build-operations/src/main/java/org/gradle/internal/operations/notify/BuildOperationProgressNotification.java
* 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 org.gradle.internal.operations.notify; import org.gradle.internal.scan.UsedByScanPlugin; /** * A notification that a build operation has made progress in some way. * * The methods of this interface are awkwardly prefixed to allow
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 24 14:19:43 UTC 2023 - 1.6K bytes - Viewed (0) -
src/runtime/testdata/testprognet/signalexec.go
register("Nop", Nop) } func SignalDuringExec() { pgrp := syscall.Getpgrp() const tries = 10 var wg sync.WaitGroup c := make(chan os.Signal, tries) signal.Notify(c, syscall.SIGWINCH) wg.Add(1) go func() { defer wg.Done() for range c { } }() for i := 0; i < tries; i++ { time.Sleep(time.Microsecond) wg.Add(2) go func() { defer wg.Done()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Dec 13 18:45:54 UTC 2021 - 1.3K bytes - Viewed (0) -
platforms/core-runtime/build-operations/src/main/java/org/gradle/internal/operations/notify/BuildOperationStartedNotification.java
* 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 org.gradle.internal.operations.notify; import org.gradle.internal.scan.UsedByScanPlugin; import javax.annotation.Nullable; /** * A notification that a build operation has started. *
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 24 14:19:43 UTC 2023 - 1.9K bytes - Viewed (0) -
platforms/enterprise/enterprise/src/main/java/org/gradle/internal/enterprise/impl/DefaultGradleEnterprisePluginAdapterFactory.java
import org.gradle.internal.enterprise.GradleEnterprisePluginConfig; import org.gradle.internal.enterprise.GradleEnterprisePluginServiceFactory; import org.gradle.internal.operations.notify.BuildOperationNotificationListenerRegistrar; import org.gradle.internal.service.scopes.Scope; import org.gradle.internal.service.scopes.ServiceScope; @ServiceScope(Scope.Build.class)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 21 11:17:11 UTC 2024 - 2.7K bytes - Viewed (0) -
platforms/core-runtime/build-operations/src/main/java/org/gradle/internal/operations/notify/BuildOperationNotificationListener.java
* 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 org.gradle.internal.operations.notify; import org.gradle.internal.scan.UsedByScanPlugin; /** * A listener to notifications about build events. * * Implementations are thread safe and can be signalled concurrently.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 24 14:19:43 UTC 2023 - 1.7K bytes - Viewed (0) -
platforms/core-configuration/model-core/src/test/groovy/org/gradle/model/internal/registry/ModelNodeInternalTest.groovy
def "should have zero executed rules initially"() { expect: new TestNode(registration).getExecutedRules().size() == 0 } def "should record executed rules when notify fired #fireCount time(s)"() { def descriptor = Mock(ModelRuleDescriptor) ModelNodeInternal modelNode = new TestNode(registration) def executionBinder = Mock(RuleBinder)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Sep 28 09:51:04 UTC 2023 - 2K bytes - Viewed (0) -
platforms/core-runtime/daemon-services/src/main/java/org/gradle/api/internal/tasks/userinput/AbstractUserInputHandler.java
} }); } protected abstract UserInteraction newInteraction(); protected interface UserInteraction extends UserQuestions { /** * Notify the client that the interaction is complete. */ void finish(); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 09 04:50:46 UTC 2024 - 2K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/TransCallNamedPipeResponse.java
TransactNamedPipeInputStream in = (TransactNamedPipeInputStream)pipe.pipeIn; synchronized( in.lock ) { in.receive( buffer, bufferIndex, len ); in.lock.notify(); } } return len; } public String toString() { return new String( "TransCallNamedPipeResponse[" + super.toString() + "]" ); }
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Fri Mar 22 21:10:40 UTC 2019 - 2K bytes - Viewed (0) -
pkg/scheduler/internal/cache/debugger/debugger.go
func (d *CacheDebugger) ListenForSignal(ctx context.Context) { logger := klog.FromContext(ctx) stopCh := ctx.Done() ch := make(chan os.Signal, 1) signal.Notify(ch, compareSignal) go func() { for { select { case <-stopCh: return case <-ch: d.Comparer.Compare(logger) d.Dumper.DumpAll(logger) } } }()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 29 05:26:32 UTC 2023 - 1.9K bytes - Viewed (0)