daniel
7 years ago
36 changed files with 816 additions and 333 deletions
@ -0,0 +1,178 @@
|
||||
/* |
||||
* Copyright (C) 2010 The Guava Authors |
||||
* |
||||
* 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 |
||||
* |
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* |
||||
* 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 com.fr.design.utils.concurrent; |
||||
|
||||
import java.lang.Thread.UncaughtExceptionHandler; |
||||
import java.util.Locale; |
||||
import java.util.concurrent.Executors; |
||||
import java.util.concurrent.ThreadFactory; |
||||
import java.util.concurrent.atomic.AtomicLong; |
||||
|
||||
/** |
||||
* A ThreadFactory builder, providing any combination of these features: |
||||
* <ul> |
||||
* <li>whether threads should be marked as {@linkplain Thread#setDaemon daemon} threads |
||||
* <li>a {@linkplain ThreadFactoryBuilder#setNameFormat naming format} |
||||
* <li>a {@linkplain Thread#setPriority thread priority} |
||||
* <li>an {@linkplain Thread#setUncaughtExceptionHandler uncaught exception handler} |
||||
* <li>a {@linkplain ThreadFactory#newThread backing thread factory} |
||||
* </ul> |
||||
* <p>If no backing thread factory is provided, a default backing thread factory is used as if by |
||||
* calling {@code setThreadFactory(}{@link Executors#defaultThreadFactory()}{@code )}. |
||||
* |
||||
* @author Kurt Alfred Kluever |
||||
* @since 4.0 |
||||
*/ |
||||
public final class ThreadFactoryBuilder { |
||||
private String nameFormat = null; |
||||
private Boolean daemon = null; |
||||
private Integer priority = null; |
||||
private UncaughtExceptionHandler uncaughtExceptionHandler = null; |
||||
private ThreadFactory backingThreadFactory = null; |
||||
|
||||
/** |
||||
* Creates a new {@link ThreadFactory} builder. |
||||
*/ |
||||
public ThreadFactoryBuilder() { |
||||
// 这个注释毫无意义，就是为了通过SonarQube
|
||||
} |
||||
|
||||
/** |
||||
* Sets the naming format to use when naming threads ({@link Thread#setName}) which are created |
||||
* with this ThreadFactory. |
||||
* |
||||
* @param nameFormat a {@link String#format(String, Object...)}-compatible format String, to which |
||||
* a unique integer (0, 1, etc.) will be supplied as the single parameter. This integer will |
||||
* be unique to the built instance of the ThreadFactory and will be assigned sequentially. For |
||||
* example, {@code "rpc-pool-%d"} will generate thread names like {@code "rpc-pool-0"}, |
||||
* {@code "rpc-pool-1"}, {@code "rpc-pool-2"}, etc. |
||||
* @return this for the builder pattern |
||||
*/ |
||||
public ThreadFactoryBuilder setNameFormat(String nameFormat) { |
||||
String unused = format(nameFormat, 0); // fail fast if the format is bad or null
|
||||
this.nameFormat = nameFormat; |
||||
return this; |
||||
} |
||||
|
||||
/** |
||||
* Sets daemon or not for new threads created with this ThreadFactory. |
||||
* |
||||
* @param daemon whether or not new Threads created with this ThreadFactory will be daemon threads |
||||
* @return this for the builder pattern |
||||
*/ |
||||
public ThreadFactoryBuilder setDaemon(boolean daemon) { |
||||
this.daemon = daemon; |
||||
return this; |
||||
} |
||||
|
||||
/** |
||||
* Sets the priority for new threads created with this ThreadFactory. |
||||
* |
||||
* @param priority the priority for new Threads created with this ThreadFactory |
||||
* @return this for the builder pattern |
||||
*/ |
||||
public ThreadFactoryBuilder setPriority(int priority) { |
||||
// Thread#setPriority() already checks for validity. These error messages
|
||||
// are nicer though and will fail-fast.
|
||||
|
||||
if (priority < Thread.MIN_PRIORITY) { |
||||
throw new IllegalArgumentException(format("Thread priority (%s) must be >= %s", priority, Thread.MIN_PRIORITY)); |
||||
} |
||||
if (priority > Thread.MAX_PRIORITY) { |
||||
throw new IllegalArgumentException(format("Thread priority (%s) must be <= %s", priority, Thread.MAX_PRIORITY)); |
||||
} |
||||
this.priority = priority; |
||||
return this; |
||||
} |
||||
|
||||
/** |
||||
* Sets the {@link UncaughtExceptionHandler} for new threads created with this ThreadFactory. |
||||
* |
||||
* @param uncaughtExceptionHandler the uncaught exception handler for new Threads created with |
||||
* this ThreadFactory |
||||
* @return this for the builder pattern |
||||
*/ |
||||
public ThreadFactoryBuilder setUncaughtExceptionHandler( |
||||
UncaughtExceptionHandler uncaughtExceptionHandler) { |
||||
if (uncaughtExceptionHandler == null) { |
||||
throw new NullPointerException(); |
||||
} |
||||
this.uncaughtExceptionHandler = uncaughtExceptionHandler; |
||||
return this; |
||||
} |
||||
|
||||
/** |
||||
* Sets the backing {@link ThreadFactory} for new threads created with this ThreadFactory. Threads |
||||
* will be created by invoking #newThread(Runnable) on this backing {@link ThreadFactory}. |
||||
* |
||||
* @param backingThreadFactory the backing {@link ThreadFactory} which will be delegated to during |
||||
* thread creation. |
||||
* @return this for the builder pattern |
||||
*/ |
||||
public ThreadFactoryBuilder setThreadFactory(ThreadFactory backingThreadFactory) { |
||||
if (backingThreadFactory == null) { |
||||
throw new NullPointerException(); |
||||
} |
||||
this.backingThreadFactory = backingThreadFactory; |
||||
return this; |
||||
} |
||||
|
||||
/** |
||||
* Returns a new thread factory using the options supplied during the building process. After |
||||
* building, it is still possible to change the options used to build the ThreadFactory and/or |
||||
* build again. State is not shared amongst built instances. |
||||
* |
||||
* @return the fully constructed {@link ThreadFactory} |
||||
*/ |
||||
public ThreadFactory build() { |
||||
return doBuild(this); |
||||
} |
||||
|
||||
// Split out so that the anonymous ThreadFactory can't contain a reference back to the builder.
|
||||
// At least, I assume that's why. TODO(cpovirk): Check, and maybe add a test for this.
|
||||
private static ThreadFactory doBuild(ThreadFactoryBuilder builder) { |
||||
final String nameFormat = builder.nameFormat; |
||||
final Boolean daemon = builder.daemon; |
||||
final Integer priority = builder.priority; |
||||
final UncaughtExceptionHandler uncaughtExceptionHandler = builder.uncaughtExceptionHandler; |
||||
final ThreadFactory backingThreadFactory = |
||||
(builder.backingThreadFactory != null) |
||||
? builder.backingThreadFactory |
||||
: Executors.defaultThreadFactory(); |
||||
final AtomicLong count = (nameFormat != null) ? new AtomicLong(0) : null; |
||||
return new ThreadFactory() { |
||||
@Override |
||||
public Thread newThread(Runnable runnable) { |
||||
Thread thread = backingThreadFactory.newThread(runnable); |
||||
if (nameFormat != null) { |
||||
thread.setName(format(nameFormat, count.getAndIncrement())); |
||||
} |
||||
if (daemon != null) { |
||||
thread.setDaemon(daemon); |
||||
} |
||||
if (priority != null) { |
||||
thread.setPriority(priority); |
||||
} |
||||
if (uncaughtExceptionHandler != null) { |
||||
thread.setUncaughtExceptionHandler(uncaughtExceptionHandler); |
||||
} |
||||
return thread; |
||||
} |
||||
}; |
||||
} |
||||
|
||||
private static String format(String format, Object... args) { |
||||
return String.format(Locale.ROOT, format, args); |
||||
} |
||||
} |
||||
@ -1 +1,140 @@
|
||||
package com.fr.design.write.submit;
import com.fr.base.GraphHelper;
import com.fr.data.AbstractClassJob;
import com.fr.design.data.tabledata.tabledatapane.ClassNameSelectPane;
import com.fr.design.beans.BasicBeanPane;
import com.fr.design.formula.JavaEditorPane;
import com.fr.design.gui.frpane.ObjectProperiesPane;
import com.fr.design.gui.ibutton.UIButton;
import com.fr.design.gui.itextarea.UITextArea;
import com.fr.design.gui.itextfield.UITextField;
import com.fr.design.layout.FRGUIPaneFactory;
import com.fr.design.dialog.BasicDialog;
import com.fr.design.dialog.DialogActionAdapter;
import com.fr.general.Inter;
import com.fr.stable.StringUtils;
import com.fr.design.utils.gui.GUICoreUtils;
import javax.swing.*;
import java.awt.*;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
/**
* Author : Shockway
* Date: 13-7-29
* Time: 下午6:48
*/
public abstract class CustomJobPane extends BasicBeanPane {
protected UITextField classNameTextField;
protected ObjectProperiesPane objectProperiesPane;
public static final int DEFAULT_LENGTH = 30;
public CustomJobPane() {
this.setLayout(FRGUIPaneFactory.createBorderLayout());
JPanel reportletNamePane = FRGUIPaneFactory.createBoxFlowInnerContainer_S_Pane();
classNameTextField = new UITextField(getLengthOfTextField());
reportletNamePane.add(classNameTextField);
UIButton browserButton = new UIButton(Inter.getLocText("FR-Designer_Select"));
browserButton.setPreferredSize(new Dimension(
GraphHelper.getLocTextWidth("FR-Designer_Select") + 20,
classNameTextField.getPreferredSize().height));
UIButton editButton = new UIButton(Inter.getLocText("FR-Designer_Edit"));
editButton.setPreferredSize(new Dimension(
GraphHelper.getLocTextWidth("FR-Designer_Edit") + 20,
classNameTextField.getPreferredSize().height));
reportletNamePane.add(browserButton);
reportletNamePane.add(editButton);
browserButton.addActionListener(new ActionListener() {
public void actionPerformed(ActionEvent evt) {
final ClassNameSelectPane bPane = new ClassNameSelectPane();
bPane.setClassPath(classNameTextField.getText());
bPane.showWindow(
SwingUtilities.getWindowAncestor(getWindowAncestor()),
new DialogActionAdapter() {
public void doOk() {
classNameTextField.setText(bPane.getClassPath());
checkAddButtonEnable();
}
}).setVisible(true);
}
});
editButton.addActionListener(new ActionListener() {
@Override
public void actionPerformed(ActionEvent e) {
final JavaEditorPane javaEditorPane = new JavaEditorPane(classNameTextField.getText(), JavaEditorPane.DEFAULT_SUBMIT_JOB);
final BasicDialog dlg = javaEditorPane.showMediumWindow(SwingUtilities.getWindowAncestor(CustomJobPane.this),
new DialogActionAdapter() {
public void doOk() {
classNameTextField.setText(javaEditorPane.getClassText());
checkAddButtonEnable();
}
});
javaEditorPane.addSaveActionListener(new ActionListener() {
@Override
public void actionPerformed(ActionEvent e) {
dlg.doOK();
}
});
dlg.setVisible(true);
}
});
reportletNamePane.setBorder(GUICoreUtils.createTitledBorder(Inter.getLocText("FR-Designer_ClassName"), null));
this.add(reportletNamePane, BorderLayout.NORTH);
objectProperiesPane = new ObjectProperiesPane();
objectProperiesPane.setBorder(GUICoreUtils.createTitledBorder(Inter.getLocText("FR-Designer_Property"), null));
this.add(objectProperiesPane, BorderLayout.CENTER);
UITextArea area = new UITextArea(2, 1);
area.setText(Inter.getLocText(new String[]{"Come_True", "Interface"}) + ":com.fr.data.SubmitJob");
JPanel dsPane = FRGUIPaneFactory.createBorderLayout_S_Pane();
dsPane.add(area);
dsPane.setBorder(GUICoreUtils.createTitledBorder(Inter.getLocText("FR-Designer_Custom_Job_Description"), null));
this.add(dsPane, BorderLayout.SOUTH);
checkAddButtonEnable();
}
public int getLengthOfTextField() {
return DEFAULT_LENGTH;
}
protected String title4PopupWindow() {
return "CustomJob";
}
protected Component getWindowAncestor() {
return this;
}
@Override
public void populateBean(Object ob) {
if (ob instanceof AbstractClassJob) {
AbstractClassJob cj = (AbstractClassJob) ob;
this.classNameTextField.setText(cj.getClassName());
this.objectProperiesPane.populateBean(cj.getPropertyMap());
checkAddButtonEnable();
}
}
/**
* 添加按钮可用
*/
public void checkAddButtonEnable() {
objectProperiesPane.enableAddButton(StringUtils.isNotEmpty(classNameTextField.getText()));
}
/**
* 重置
*/
public void reset() {
this.classNameTextField.setText(null);
this.checkAddButtonEnable();
}
} |
||||
package com.fr.design.write.submit; |
||||
|
||||
import com.fr.base.GraphHelper; |
||||
import com.fr.data.AbstractClassJob; |
||||
import com.fr.design.data.tabledata.tabledatapane.ClassNameSelectPane; |
||||
import com.fr.design.beans.BasicBeanPane; |
||||
import com.fr.design.formula.JavaEditorPane; |
||||
import com.fr.design.gui.frpane.ObjectProperiesPane; |
||||
import com.fr.design.gui.ibutton.UIButton; |
||||
import com.fr.design.gui.itextarea.UITextArea; |
||||
import com.fr.design.gui.itextfield.UITextField; |
||||
import com.fr.design.layout.FRGUIPaneFactory; |
||||
import com.fr.design.dialog.BasicDialog; |
||||
import com.fr.design.dialog.DialogActionAdapter; |
||||
import com.fr.general.Inter; |
||||
import com.fr.stable.StringUtils; |
||||
import com.fr.design.utils.gui.GUICoreUtils; |
||||
|
||||
import javax.swing.*; |
||||
import java.awt.*; |
||||
import java.awt.event.ActionEvent; |
||||
import java.awt.event.ActionListener; |
||||
|
||||
/** |
||||
* Author : Shockway |
||||
* Date: 13-7-29 |
||||
* Time: 下午6:48 |
||||
*/ |
||||
public abstract class CustomJobPane extends BasicBeanPane { |
||||
protected UITextField classNameTextField; |
||||
protected ObjectProperiesPane objectProperiesPane; |
||||
public static final int DEFAULT_LENGTH = 30; |
||||
|
||||
public CustomJobPane() { |
||||
this.setLayout(FRGUIPaneFactory.createBorderLayout()); |
||||
JPanel reportletNamePane = FRGUIPaneFactory.createBoxFlowInnerContainer_S_Pane(); |
||||
classNameTextField = new UITextField(getLengthOfTextField()); |
||||
reportletNamePane.add(classNameTextField); |
||||
|
||||
UIButton browserButton = new UIButton(Inter.getLocText("FR-Designer_Select")); |
||||
browserButton.setPreferredSize(new Dimension( |
||||
GraphHelper.getLocTextWidth("FR-Designer_Select") + 20, |
||||
classNameTextField.getPreferredSize().height)); |
||||
|
||||
UIButton editButton = new UIButton(Inter.getLocText("FR-Designer_Edit")); |
||||
editButton.setPreferredSize(new Dimension( |
||||
GraphHelper.getLocTextWidth("FR-Designer_Edit") + 20, |
||||
classNameTextField.getPreferredSize().height)); |
||||
|
||||
reportletNamePane.add(browserButton); |
||||
reportletNamePane.add(editButton); |
||||
|
||||
browserButton.addActionListener(new ActionListener() { |
||||
public void actionPerformed(ActionEvent evt) { |
||||
final ClassNameSelectPane bPane = new ClassNameSelectPane(); |
||||
bPane.setClassPath(classNameTextField.getText()); |
||||
bPane.showWindow( |
||||
SwingUtilities.getWindowAncestor(getWindowAncestor()), |
||||
new DialogActionAdapter() { |
||||
public void doOk() { |
||||
classNameTextField.setText(bPane.getClassPath()); |
||||
checkAddButtonEnable(); |
||||
} |
||||
}).setVisible(true); |
||||
} |
||||
}); |
||||
editButton.addActionListener(new ActionListener() { |
||||
@Override |
||||
public void actionPerformed(ActionEvent e) { |
||||
final JavaEditorPane javaEditorPane = new JavaEditorPane(classNameTextField.getText(), JavaEditorPane.DEFAULT_SUBMIT_JOB); |
||||
final BasicDialog dlg = javaEditorPane.showMediumWindow(SwingUtilities.getWindowAncestor(CustomJobPane.this), |
||||
new DialogActionAdapter() { |
||||
public void doOk() { |
||||
classNameTextField.setText(javaEditorPane.getClassText()); |
||||
checkAddButtonEnable(); |
||||
} |
||||
}); |
||||
javaEditorPane.addSaveActionListener(new ActionListener() { |
||||
@Override |
||||
public void actionPerformed(ActionEvent e) { |
||||
dlg.doOK(); |
||||
} |
||||
}); |
||||
dlg.setVisible(true); |
||||
} |
||||
}); |
||||
|
||||
reportletNamePane.setBorder(GUICoreUtils.createTitledBorder(Inter.getLocText("FR-Designer_ClassName"), null)); |
||||
this.add(reportletNamePane, BorderLayout.NORTH); |
||||
|
||||
objectProperiesPane = new ObjectProperiesPane(); |
||||
objectProperiesPane.setBorder(GUICoreUtils.createTitledBorder(Inter.getLocText("FR-Designer_Property"), null)); |
||||
this.add(objectProperiesPane, BorderLayout.CENTER); |
||||
|
||||
UITextArea area = new UITextArea(2, 1); |
||||
area.setText(Inter.getLocText(new String[]{"Come_True", "Interface"}) + ":com.fr.data.AbstractSubmitTask"); |
||||
JPanel dsPane = FRGUIPaneFactory.createBorderLayout_S_Pane(); |
||||
dsPane.add(area); |
||||
dsPane.setBorder(GUICoreUtils.createTitledBorder(Inter.getLocText("FR-Designer_Custom_Job_Description"), null)); |
||||
this.add(dsPane, BorderLayout.SOUTH); |
||||
checkAddButtonEnable(); |
||||
} |
||||
|
||||
public int getLengthOfTextField() { |
||||
return DEFAULT_LENGTH; |
||||
} |
||||
|
||||
protected String title4PopupWindow() { |
||||
return "CustomJob"; |
||||
} |
||||
|
||||
protected Component getWindowAncestor() { |
||||
return this; |
||||
} |
||||
|
||||
@Override |
||||
public void populateBean(Object ob) { |
||||
if (ob instanceof AbstractClassJob) { |
||||
AbstractClassJob cj = (AbstractClassJob) ob; |
||||
this.classNameTextField.setText(cj.getClassName()); |
||||
this.objectProperiesPane.populateBean(cj.getPropertyMap()); |
||||
checkAddButtonEnable(); |
||||
} |
||||
} |
||||
|
||||
/** |
||||
* 添加按钮可用 |
||||
*/ |
||||
public void checkAddButtonEnable() { |
||||
objectProperiesPane.enableAddButton(StringUtils.isNotEmpty(classNameTextField.getText())); |
||||
} |
||||
|
||||
/** |
||||
* 重置 |
||||
*/ |
||||
public void reset() { |
||||
this.classNameTextField.setText(null); |
||||
this.checkAddButtonEnable(); |
||||
} |
||||
} |
||||
Loading…
Reference in new issue